package com.sg.service.biz.app.impl;

import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.collection.CollectionUtil;
import com.sg.common.util.CommonFunctionHelper;
import com.sg.common.util.RedisUtil;
import com.sg.dto.biz.app.req.*;
import com.sg.dto.biz.app.res.*;
import com.sg.dto.integration.component.QueryConfItemMatchAnswerDetailComReqDto;
import com.sg.service.base.app.MOmsEvaluationObjectTargetCycleService;
import com.sg.service.base.app.MOmsOfficialDocumentService;
import com.sg.service.biz.app.*;
import com.sg.common.exception.Assert;
import com.wicket.okrapp.common.exception.BizException;
import com.wicket.okrcomponent.integration.*;
import com.wicket.okrcomponent.integration.dto.*;
import com.wicket.okrframework.integration.BatchService;
import com.wicket.okrframework.integration.InductionRecordService;
import com.wicket.okrframework.integration.OrgService;
import com.wicket.okrframework.integration.dto.*;
import org.apache.skywalking.apm.toolkit.trace.Tag;
import org.apache.skywalking.apm.toolkit.trace.Tags;
import org.apache.skywalking.apm.toolkit.trace.Trace;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.List;
import java.util.stream.Collectors;

/**
 * @author ：
 * @version 1.0
 * @date ：
 */
@Service
public class OfficialDocumentServiceImpl
        implements com.wicket.okrapp.biz.service.OfficialDocumentService {

    @Resource
    private RedisUtil redisUtil;
    @Resource
    private MOmsOfficialDocumentService mOmsOfficialDocumentService;
    @Resource
    private InductionRecordService inductionRecordService;
    @Resource
    private BatchService batchService;
    @Resource
    private MessageService fwCompMessageClient;
    @Resource
    private UnstructuredDataService unstructuredDataService;
    @Resource
    private UnstructuredDataService unstructuredDataService;
    @Resource
    private InterfaceModeService interfaceModeService;
    @Resource
    private PlanDataService planDataService;
    @Resource
    private MOmsEvaluationObjectTargetCycleService mOmsEvaluationObjectTargetCycleService;
    @Resource
    private NbOfficialDocument nbOfficialDocument;
    @Resource
    private WorkTasksService workTasksService;
    @Resource
    private OrgService orgService;
    @Resource
    private VirtualOrgService virtualOrgService;
    @Resource
    private MessageService messageService;
    @Resource
    private DataSetSingleEntryService fwCompDataSetSingleEntryClient;
    @Resource
    private ConfSchemeService confSchemeService;
//@Resource
    //private MSpecMethordTableService mSpecMethordTableService;

    /**
     * D3修改公文[7928]
     * gen by moon at 7/18/2024, 6:34:32 PM
     */
    @Trace(operationName = "D3修改公文")
    @Tags({@Tag(key = "参数", value = "arg[0]"),
            @Tag(key = "返回值", value = "returnedObj")})
    @Transactional(rollbackFor = Exception.class)
    @Override
    public UpdateOfficialDocumentRespDto updateOfficialDocument(UpdateOfficialDocumentReqDto reqDto) {


        //virtualUsage D3-9修改公文主体(公共)  53522
        UpdateOfficialDocumentBodyComRespDto updateOfficialDocumentBodyComRespDto = null;
        UpdateOfficialDocumentBodyComReqDto updateOfficialDocumentBodyComReqDto = new UpdateOfficialDocumentBodyComReqDto();
        if (reqDto != null) {
            updateOfficialDocumentBodyComReqDto.setOfficialDocumentId(reqDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1311574_1_53522
            updateOfficialDocumentBodyComReqDto.setOfficialDocumentName(reqDto.getOfficialDocumentName());//SimpleFieldAssign//sourceId:1311575_1_53522
            updateOfficialDocumentBodyComReqDto.setReceiveRange(reqDto.getReceiveRange());//SimpleFieldAssign//sourceId:1385476_1_53522
            updateOfficialDocumentBodyComReqDto.setRemindLevel(reqDto.getRemindLevel());//SimpleFieldAssign//sourceId:1311578_1_53522
            updateOfficialDocumentBodyComReqDto.setAppointWorkTaskArrangeInductionId(reqDto.getAppointWorkTaskArrangeInductionId());//SimpleFieldAssign//sourceId:1311581_1_53522
            updateOfficialDocumentBodyComReqDto.setSubjectLifeCycle(reqDto.getSubjectLifeCycle());//SimpleFieldAssign//sourceId:1311582_1_53522
        }

        /*D3-9修改公文主体(公共)[7923]   */
        Assert.isNull(updateOfficialDocumentBodyComReqDto.getOfficialDocumentId(), "D3修改公文-D3-9修改公文主体(公共)-公文ID不能为空", false);
        updateOfficialDocumentBodyComRespDto = updateOfficialDocumentBodyCom(updateOfficialDocumentBodyComReqDto)/*vcase invoke 同服务,同domain*/;


        if ((reqDto != null && reqDto.getOfficialDocumentUnstructuredDataId() != null)) {
            //if(D3修改公文.公文文档ID 值不等于空 )  53635

            ImplementSingleMultipleFieldSetDataEntryComRespDto implementSingleMultipleFieldSetDataEntryComRespDto = null;
            ImplementSingleMultipleFieldSetDataEntryComReqDto implementSingleMultipleFieldSetDataEntryComReqDto = new ImplementSingleMultipleFieldSetDataEntryComReqDto();
            if (reqDto != null) {
                implementSingleMultipleFieldSetDataEntryComReqDto.setCustomField1(reqDto.getOfficialDocumentUnstructuredDataId());//SimpleFieldAssign//sourceId:1857014_1_69766
                implementSingleMultipleFieldSetDataEntryComReqDto.setCustomField2(reqDto.getPostfix());//SimpleFieldAssign//sourceId:1857015_1_69766
                implementSingleMultipleFieldSetDataEntryComReqDto.setCustomField3(reqDto.getFileRelativePathAccess());//SimpleFieldAssign//sourceId:1857016_1_69766
                implementSingleMultipleFieldSetDataEntryComReqDto.setCustomField4(reqDto.getSourceRelationshipId());//SimpleFieldAssign//sourceId:1857017_1_69766
                implementSingleMultipleFieldSetDataEntryComReqDto.setCustomField5(reqDto.getRelationshipType());//SimpleFieldAssign//sourceId:1857018_1_69766
                implementSingleMultipleFieldSetDataEntryComReqDto.setCustomField6(reqDto.getIsNetworkReference());//SimpleFieldAssign//sourceId:1857019_1_69766
            }

            /*D2执行单条多字段转数据集(公共)[9762]   */
            Assert.isNull(implementSingleMultipleFieldSetDataEntryComReqDto.getCustomField1(), "D3修改公文-D2执行单条多字段转数据集(公共)-自定义字段1不能为空", false);
            Assert.isNull(implementSingleMultipleFieldSetDataEntryComReqDto.getCustomField2(), "D3修改公文-D2执行单条多字段转数据集(公共)-自定义字段2不能为空", false);
            Assert.isNull(implementSingleMultipleFieldSetDataEntryComReqDto.getCustomField3(), "D3修改公文-D2执行单条多字段转数据集(公共)-自定义字段3不能为空", false);
            implementSingleMultipleFieldSetDataEntryComRespDto = fwCompDataSetSingleEntryClient.implementSingleMultipleFieldSetDataEntryCom(implementSingleMultipleFieldSetDataEntryComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;


            ImplementSeparateAddOrDeleteDocListComRespDto implementSeparateAddOrDeleteDocListComRespDto = null;
            if (implementSingleMultipleFieldSetDataEntryComRespDto != null) {
                ImplementSeparateAddOrDeleteDocListComReqDto implementSeparateAddOrDeleteDocListComReqDto = new ImplementSeparateAddOrDeleteDocListComReqDto();
                implementSeparateAddOrDeleteDocListComReqDto.setIsCleanPersonalInvalidDocument("FALSE");//sourceId:1934778_1_69762
                implementSeparateAddOrDeleteDocListComReqDto.setDocUseSceneCode("WORK_TASKS");//sourceId:1856870_1_69762
                implementSeparateAddOrDeleteDocListComReqDto.setDocUseType("OFFICIAL_DOCUMENT_FILE");//sourceId:1856871_1_69762
                implementSeparateAddOrDeleteDocListComReqDto.setIsResult("FALSE");//sourceId:1859369_1_69762
                implementSeparateAddOrDeleteDocListComReqDto.setOwnTableTypeCode("OMS_OFFICIAL_DOCUMENT");//sourceId:1856873_1_69762
                implementSeparateAddOrDeleteDocListComReqDto.setUserId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecUserId());//CURRENT_USERID//sourceId:1856879_1_69762
                implementSeparateAddOrDeleteDocListComReqDto.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1856868_1_69762
                if (implementSingleMultipleFieldSetDataEntryComRespDto != null && implementSingleMultipleFieldSetDataEntryComRespDto.getComDatasList() != null && !CollectionUtil.isEmpty(implementSingleMultipleFieldSetDataEntryComRespDto.getComDatasList())) {
                    implementSeparateAddOrDeleteDocListComReqDto.setDocumentList(//objList-to-objLists
                            implementSingleMultipleFieldSetDataEntryComRespDto.getComDatasList().stream().map(item -> {
                                com.wicket.okrcomponent.integration.dto.DocumentDto elm = new com.wicket.okrcomponent.integration.dto.DocumentDto();
                                if (item != null) {
                                    elm.setUnstructuredDataId(item.getCustomField1());//SimpleFieldAssign//sourceId:371956_2_69762
                                    elm.setPostfix(item.getCustomField2());//SimpleFieldAssign//sourceId:371960_2_69762
                                    elm.setFileRelativePathAccess(item.getCustomField3());//SimpleFieldAssign//sourceId:371961_2_69762
                                    elm.setSourceRelationshipId(item.getCustomField4());//SimpleFieldAssign//sourceId:371957_2_69762
                                    elm.setRelationshipType(item.getCustomField5());//SimpleFieldAssign//sourceId:371958_2_69762
                                    elm.setIsNetworkReference(item.getCustomField6());//SimpleFieldAssign//sourceId:371959_2_69762
                                }
                                return elm;
                            }).collect(Collectors.toList()));//objList-to-objLists//sourceId:1856869_1_69762
                }
                if (reqDto != null) {
                    implementSeparateAddOrDeleteDocListComReqDto.setOwnEntityId(reqDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1856867_1_69762
                }

                /*D2新增或删除公文文档列表(公共)[8783]   */
                Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto.getIsCleanPersonalInvalidDocument(), "D3修改公文-D2新增或删除公文文档列表(公共)-是否清理个人无效文档不能为空", false);
                Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto.getDocUseSceneCode(), "D3修改公文-D2新增或删除公文文档列表(公共)-文档应用业务场景不能为空", false);
                Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto.getDocUseType(), "D3修改公文-D2新增或删除公文文档列表(公共)-文档用途类型不能为空", false);
                Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto.getIsResult(), "D3修改公文-D2新增或删除公文文档列表(公共)-冗余是否结果文档不能为空", false);
                Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto.getOwnEntityId(), "D3修改公文-D2新增或删除公文文档列表(公共)-归属内容表主键ID不能为空", false);
                Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto.getOwnTableTypeCode(), "D3修改公文-D2新增或删除公文文档列表(公共)-归属内容表类型编码不能为空", false);
                Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto.getUserId(), "D3修改公文-D2新增或删除公文文档列表(公共)-归属个人账号不能为空", false);
                Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto.getSpaceId(), "D3修改公文-D2新增或删除公文文档列表(公共)-创建于空间ID不能为空", false);
                implementSeparateAddOrDeleteDocListComRespDto = unstructuredDataService.implementSeparateAddOrDeleteDocListCom(implementSeparateAddOrDeleteDocListComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;


            }
            UpdateOfficialDocumentBodyComRespDto updateOfficialDocumentBodyComRespDto_1 = null;
            UpdateOfficialDocumentBodyComReqDto updateOfficialDocumentBodyComReqDto_1 = new UpdateOfficialDocumentBodyComReqDto();
            if (reqDto != null) {
                updateOfficialDocumentBodyComReqDto_1.setOfficialDocumentId(reqDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1311574_1_53781
                updateOfficialDocumentBodyComReqDto_1.setOfficialDocumentFileAddress(reqDto.getFileRelativePathAccess());//SimpleFieldAssign//sourceId:1385546_1_53781
            }

            /*D3-9修改公文主体(公共)[7923]   */
            Assert.isNull(updateOfficialDocumentBodyComReqDto_1.getOfficialDocumentId(), "D3修改公文-D3-9修改公文主体(公共)-公文ID不能为空", false);
            updateOfficialDocumentBodyComRespDto_1 = updateOfficialDocumentBodyCom(updateOfficialDocumentBodyComReqDto_1)/*vcase invoke 同服务,同domain*/;


        }
        if ((reqDto != null && reqDto.getBusAppDocRelaList() != null && reqDto.getBusAppDocRelaList().size() > 0)) {
            //if(D3修改公文.业务应用文档关系列表数据集条数 大于 0)  53638

            ImplementSeparateAddOrDeleteDocListComRespDto implementSeparateAddOrDeleteDocListComRespDto_1 = null;
            ImplementSeparateAddOrDeleteDocListComReqDto implementSeparateAddOrDeleteDocListComReqDto_1 = new ImplementSeparateAddOrDeleteDocListComReqDto();
            implementSeparateAddOrDeleteDocListComReqDto_1.setIsCleanPersonalInvalidDocument("FALSE");//sourceId:1934780_1_69763
            implementSeparateAddOrDeleteDocListComReqDto_1.setDocUseSceneCode("WORK_TASKS");//sourceId:1856887_1_69763
            implementSeparateAddOrDeleteDocListComReqDto_1.setDocUseType("OFFICIAL_DOCUMENT_ANNEX");//sourceId:1856888_1_69763
            implementSeparateAddOrDeleteDocListComReqDto_1.setIsResult("FALSE");//sourceId:1859370_1_69763
            implementSeparateAddOrDeleteDocListComReqDto_1.setOwnTableTypeCode("OMS_OFFICIAL_DOCUMENT");//sourceId:1856890_1_69763
            implementSeparateAddOrDeleteDocListComReqDto_1.setUserId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecUserId());//CURRENT_USERID//sourceId:1856896_1_69763
            implementSeparateAddOrDeleteDocListComReqDto_1.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1856885_1_69763
            if (reqDto != null && reqDto.getBusAppDocRelaList() != null && !CollectionUtil.isEmpty(reqDto.getBusAppDocRelaList())) {
                implementSeparateAddOrDeleteDocListComReqDto_1.setDocumentList(reqDto.getBusAppDocRelaList().stream().map(item -> BeanUtil.toBean(item, com.wicket.okrcomponent.integration.dto.DocumentDto.class)).collect(Collectors.toList()));//objList-to-objLists//sourceId:1856886_1_69763
            }
            if (reqDto != null) {
                implementSeparateAddOrDeleteDocListComReqDto_1.setOwnEntityId(reqDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1856884_1_69763
            }

            /*D2新增或删除公文附件文档列表(公共)[8783]   */
            Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto_1.getIsCleanPersonalInvalidDocument(), "D3修改公文-D2新增或删除公文附件文档列表(公共)-是否清理个人无效文档不能为空", false);
            Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto_1.getDocUseSceneCode(), "D3修改公文-D2新增或删除公文附件文档列表(公共)-文档应用业务场景不能为空", false);
            Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto_1.getDocUseType(), "D3修改公文-D2新增或删除公文附件文档列表(公共)-文档用途类型不能为空", false);
            Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto_1.getIsResult(), "D3修改公文-D2新增或删除公文附件文档列表(公共)-冗余是否结果文档不能为空", false);
            Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto_1.getOwnEntityId(), "D3修改公文-D2新增或删除公文附件文档列表(公共)-归属内容表主键ID不能为空", false);
            Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto_1.getOwnTableTypeCode(), "D3修改公文-D2新增或删除公文附件文档列表(公共)-归属内容表类型编码不能为空", false);
            Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto_1.getUserId(), "D3修改公文-D2新增或删除公文附件文档列表(公共)-归属个人账号不能为空", false);
            Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto_1.getSpaceId(), "D3修改公文-D2新增或删除公文附件文档列表(公共)-创建于空间ID不能为空", false);
            implementSeparateAddOrDeleteDocListComRespDto_1 = unstructuredDataService.implementSeparateAddOrDeleteDocListCom(implementSeparateAddOrDeleteDocListComReqDto_1).getData()/*vcase invoke 跨dubbo调用;*/;


            ImplementDataAppointFormatShiftTextComRespDto implementDataAppointFormatShiftTextComRespDto = null;
            ImplementDataAppointFormatShiftTextComReqDto implementDataAppointFormatShiftTextComReqDto = new ImplementDataAppointFormatShiftTextComReqDto();
            implementDataAppointFormatShiftTextComReqDto.setCustomField1("；");//CUSTOM_CONVENTION//sourceId:1317426_1_53784
            if (reqDto != null && reqDto.getBusAppDocRelaList() != null && !CollectionUtil.isEmpty(reqDto.getBusAppDocRelaList())) {
                implementDataAppointFormatShiftTextComReqDto.setDataAppointFormatShiftTextList(reqDto.getBusAppDocRelaList().stream().map(item -> item.getFileRelativePathAccess())
                        .collect(Collectors.toList()));/*list-to-strings*///sourceId:1317425_1_53784
            }

            /*D2附件相对路径数据集转单字段[7515]   */
            Assert.isNull(implementDataAppointFormatShiftTextComReqDto.getCustomField1(), "D3修改公文-D2附件相对路径数据集转单字段-自定义字段1不能为空", false);
            implementDataAppointFormatShiftTextComRespDto = interfaceModeService.implementDataAppointFormatShiftTextCom(implementDataAppointFormatShiftTextComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;


            UpdateOfficialDocumentBodyComRespDto updateOfficialDocumentBodyComRespDto_2 = null;
            if (implementDataAppointFormatShiftTextComRespDto != null) {
                UpdateOfficialDocumentBodyComReqDto updateOfficialDocumentBodyComReqDto_2 = new UpdateOfficialDocumentBodyComReqDto();
                if (reqDto != null) {
                    updateOfficialDocumentBodyComReqDto_2.setOfficialDocumentId(reqDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1311574_1_53785
                }
                if (implementDataAppointFormatShiftTextComRespDto != null) {
                    updateOfficialDocumentBodyComReqDto_2.setAnnexAddress(implementDataAppointFormatShiftTextComRespDto.getCustomText());//SimpleFieldAssign//sourceId:1385547_1_53785
                }

                /*D3-9修改公文主体(公共)[7923]   */
                Assert.isNull(updateOfficialDocumentBodyComReqDto_2.getOfficialDocumentId(), "D3修改公文-D3-9修改公文主体(公共)-公文ID不能为空", false);
                updateOfficialDocumentBodyComRespDto_2 = updateOfficialDocumentBodyCom(updateOfficialDocumentBodyComReqDto_2)/*vcase invoke 同服务,同domain*/;


            }
        }
        if ((reqDto != null && reqDto.getSubjectLifeCycle() != null && reqDto.getSubjectLifeCycle().equals("CURRENTLY_VALID"))) {
            //if(D3修改公文.主体生命周期 等于 当前有效)  53523

            QueryOfficialDocumentDetailComRespDto queryOfficialDocumentDetailComRespDto = null;
            QueryOfficialDocumentDetailComReqDto queryOfficialDocumentDetailComReqDto = new QueryOfficialDocumentDetailComReqDto();
            queryOfficialDocumentDetailComReqDto.setIsArchive("FALSE");//sourceId:1311742_1_53524
            queryOfficialDocumentDetailComReqDto.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1311710_1_53524
            if (reqDto != null) {
                queryOfficialDocumentDetailComReqDto.setOfficialDocumentId(reqDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1311704_1_53524
            }

            /*D3-9查询公文详情(公共)[7930]   */
            Assert.isNull(queryOfficialDocumentDetailComReqDto.getOfficialDocumentId(), "D3修改公文-D3-9查询公文详情(公共)-公文ID不能为空", false);
            Assert.isNull(queryOfficialDocumentDetailComReqDto.getIsArchive(), "D3修改公文-D3-9查询公文详情(公共)-是否存档不能为空", false);
            Assert.isNull(queryOfficialDocumentDetailComReqDto.getSpaceId(), "D3修改公文-D3-9查询公文详情(公共)-创建于空间ID不能为空", false);
            queryOfficialDocumentDetailComRespDto = queryOfficialDocumentDetailCom(queryOfficialDocumentDetailComReqDto)/*vcase invoke 同服务,同domain*/;


            ImplementNotificationTypeMsgTempanAlyzeComRespDto implementNotificationTypeMsgTempanAlyzeComRespDto = null;
            if (queryOfficialDocumentDetailComRespDto != null) {
                ImplementNotificationTypeMsgTempanAlyzeComReqDto implementNotificationTypeMsgTempanAlyzeComReqDto = new ImplementNotificationTypeMsgTempanAlyzeComReqDto();
                if (queryOfficialDocumentDetailComRespDto != null) {
                    implementNotificationTypeMsgTempanAlyzeComReqDto.setNotificationType(queryOfficialDocumentDetailComRespDto.getNotificationType());//SimpleFieldAssign//sourceId:1418224_1_56691
                    implementNotificationTypeMsgTempanAlyzeComReqDto.setReceiveRange(queryOfficialDocumentDetailComRespDto.getReceiveRange());//SimpleFieldAssign//sourceId:1418225_1_56691
                }

                /*D3执行通知类型消息模板分析(公共)[8153]   */
                Assert.isNull(implementNotificationTypeMsgTempanAlyzeComReqDto.getNotificationType(), "D3修改公文-D3执行通知类型消息模板分析(公共)-通知类型不能为空", false);
                Assert.isNull(implementNotificationTypeMsgTempanAlyzeComReqDto.getReceiveRange(), "D3修改公文-D3执行通知类型消息模板分析(公共)-接收范围不能为空", false);
                implementNotificationTypeMsgTempanAlyzeComRespDto = implementNotificationTypeMsgTempanAlyzeCom(implementNotificationTypeMsgTempanAlyzeComReqDto)/*vcase invoke 同服务,同domain*/;


            }
            if ((queryOfficialDocumentDetailComRespDto != null && queryOfficialDocumentDetailComRespDto.getReceiveRange() != null && queryOfficialDocumentDetailComRespDto.getReceiveRange().equals("EVERYONE"))) {
                //if(D3-9查询公文详情(公共).接收范围 等于 所有人)  54074

                ImplementIssueOfficialDoSendOrgMemberMsgComRespDto implementIssueOfficialDoSendOrgMemberMsgComRespDto = null;
                if (queryOfficialDocumentDetailComRespDto != null && implementNotificationTypeMsgTempanAlyzeComRespDto != null) {
                    ImplementIssueOfficialDoSendOrgMemberMsgComReqDto implementIssueOfficialDoSendOrgMemberMsgComReqDto = new ImplementIssueOfficialDoSendOrgMemberMsgComReqDto();
                    implementIssueOfficialDoSendOrgMemberMsgComReqDto.setCooperateContentTypeCode("OMS_OFFICIAL_DOCUMENT");//sourceId:1331860_1_54168
                    if (reqDto != null) {
                        implementIssueOfficialDoSendOrgMemberMsgComReqDto.setOfficialDocumentId(reqDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1328780_1_54168
                        implementIssueOfficialDoSendOrgMemberMsgComReqDto.setCooperateContentId(reqDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1331861_1_54168
                    }
                    if (queryOfficialDocumentDetailComRespDto != null) {
                        implementIssueOfficialDoSendOrgMemberMsgComReqDto.setOfficialDocumentName(queryOfficialDocumentDetailComRespDto.getOfficialDocumentName());//SimpleFieldAssign//sourceId:1328781_1_54168
                        implementIssueOfficialDoSendOrgMemberMsgComReqDto.setMessageImportantLevel(queryOfficialDocumentDetailComRespDto.getRemindLevel());//SimpleFieldAssign//sourceId:1328801_1_54168
                        implementIssueOfficialDoSendOrgMemberMsgComReqDto.setSurfaceContName(queryOfficialDocumentDetailComRespDto.getOfficialDocumentName());//SimpleFieldAssign//sourceId:1331862_1_54168
                    }
                    if (implementNotificationTypeMsgTempanAlyzeComRespDto != null) {
                        implementIssueOfficialDoSendOrgMemberMsgComReqDto.setSendMsgScene(implementNotificationTypeMsgTempanAlyzeComRespDto.getSendMsgScene());//SimpleFieldAssign//sourceId:1465841_1_54168
                        implementIssueOfficialDoSendOrgMemberMsgComReqDto.setMessageTemplateCode(implementNotificationTypeMsgTempanAlyzeComRespDto.getMessageTemplateCode());//SimpleFieldAssign//sourceId:1464895_1_54168
                        implementIssueOfficialDoSendOrgMemberMsgComReqDto.setMsgTitleTemplateSemanticEngineCode(implementNotificationTypeMsgTempanAlyzeComRespDto.getMsgTitleTemplateSemanticEngineCode());//SimpleFieldAssign//sourceId:1465842_1_54168
                    }

                    /*D3执行下发公文给组织成员发消息(公共)[7968]   */
                    Assert.isNull(implementIssueOfficialDoSendOrgMemberMsgComReqDto.getOfficialDocumentId(), "D3修改公文-D3执行下发公文给组织成员发消息(公共)-公文ID不能为空", false);
                    Assert.isNull(implementIssueOfficialDoSendOrgMemberMsgComReqDto.getOfficialDocumentName(), "D3修改公文-D3执行下发公文给组织成员发消息(公共)-公文名称不能为空", false);
                    Assert.isNull(implementIssueOfficialDoSendOrgMemberMsgComReqDto.getMessageImportantLevel(), "D3修改公文-D3执行下发公文给组织成员发消息(公共)-消息重要紧急度层级不能为空", false);
                    Assert.isNull(implementIssueOfficialDoSendOrgMemberMsgComReqDto.getCooperateContentTypeCode(), "D3修改公文-D3执行下发公文给组织成员发消息(公共)-协同内容类型编码不能为空", false);
                    Assert.isNull(implementIssueOfficialDoSendOrgMemberMsgComReqDto.getCooperateContentId(), "D3修改公文-D3执行下发公文给组织成员发消息(公共)-协同内容ID不能为空", false);
                    Assert.isNull(implementIssueOfficialDoSendOrgMemberMsgComReqDto.getSurfaceContName(), "D3修改公文-D3执行下发公文给组织成员发消息(公共)-协同内容名称不能为空", false);
                    Assert.isNull(implementIssueOfficialDoSendOrgMemberMsgComReqDto.getSendMsgScene(), "D3修改公文-D3执行下发公文给组织成员发消息(公共)-发送消息场景不能为空", false);
                    Assert.isNull(implementIssueOfficialDoSendOrgMemberMsgComReqDto.getMessageTemplateCode(), "D3修改公文-D3执行下发公文给组织成员发消息(公共)-消息模板标识不能为空", false);
                    Assert.isNull(implementIssueOfficialDoSendOrgMemberMsgComReqDto.getMsgTitleTemplateSemanticEngineCode(), "D3修改公文-D3执行下发公文给组织成员发消息(公共)-消息标题模板引擎标识不能为空", false);
                    implementIssueOfficialDoSendOrgMemberMsgComRespDto = messageService.implementIssueOfficialDoSendOrgMemberMsgCom(implementIssueOfficialDoSendOrgMemberMsgComReqDto)/*vcase invoke isSameApp*/;


                }
            } else if ((queryOfficialDocumentDetailComRespDto != null && queryOfficialDocumentDetailComRespDto.getReceiveRange() != null && queryOfficialDocumentDetailComRespDto.getReceiveRange().equals("DEPT") && reqDto != null && reqDto.getDeptList() != null && reqDto.getDeptList().size() > 0)) {
                //elseif((D3-9查询公文详情(公共).接收范围 等于 部门 and D3修改公文.部门列表数据集条数 大于 0))  54075

                ImplementIssueOfficialDoSendDeptMemberMsgComRespDto implementIssueOfficialDoSendDeptMemberMsgComRespDto = null;
                if (queryOfficialDocumentDetailComRespDto != null && implementNotificationTypeMsgTempanAlyzeComRespDto != null) {
                    ImplementIssueOfficialDoSendDeptMemberMsgComReqDto implementIssueOfficialDoSendDeptMemberMsgComReqDto = new ImplementIssueOfficialDoSendDeptMemberMsgComReqDto();
                    implementIssueOfficialDoSendDeptMemberMsgComReqDto.setCooperateContentTypeCode("OMS_OFFICIAL_DOCUMENT");//sourceId:1331848_1_54169
                    if (reqDto != null && reqDto.getDeptList() != null && !CollectionUtil.isEmpty(reqDto.getDeptList())) {
                        implementIssueOfficialDoSendDeptMemberMsgComReqDto.setDeptList(reqDto.getDeptList().stream().map(item -> BeanUtil.toBean(item, DeptDto.class)).collect(Collectors.toList()));//objList-to-objLists//sourceId:1328782_1_54169
                    }
                    if (reqDto != null) {
                        implementIssueOfficialDoSendDeptMemberMsgComReqDto.setOfficialDocumentId(reqDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1328783_1_54169
                        implementIssueOfficialDoSendDeptMemberMsgComReqDto.setCooperateContentId(reqDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1331849_1_54169
                    }
                    if (queryOfficialDocumentDetailComRespDto != null) {
                        implementIssueOfficialDoSendDeptMemberMsgComReqDto.setOfficialDocumentName(queryOfficialDocumentDetailComRespDto.getOfficialDocumentName());//SimpleFieldAssign//sourceId:1328784_1_54169
                        implementIssueOfficialDoSendDeptMemberMsgComReqDto.setMessageImportantLevel(queryOfficialDocumentDetailComRespDto.getRemindLevel());//SimpleFieldAssign//sourceId:1328802_1_54169
                        implementIssueOfficialDoSendDeptMemberMsgComReqDto.setSurfaceContName(queryOfficialDocumentDetailComRespDto.getOfficialDocumentName());//SimpleFieldAssign//sourceId:1331850_1_54169
                    }
                    if (implementNotificationTypeMsgTempanAlyzeComRespDto != null) {
                        implementIssueOfficialDoSendDeptMemberMsgComReqDto.setSendMsgScene(implementNotificationTypeMsgTempanAlyzeComRespDto.getSendMsgScene());//SimpleFieldAssign//sourceId:1464892_1_54169
                        implementIssueOfficialDoSendDeptMemberMsgComReqDto.setMessageTemplateCode(implementNotificationTypeMsgTempanAlyzeComRespDto.getMessageTemplateCode());//SimpleFieldAssign//sourceId:1464893_1_54169
                        implementIssueOfficialDoSendDeptMemberMsgComReqDto.setMsgTitleTemplateSemanticEngineCode(implementNotificationTypeMsgTempanAlyzeComRespDto.getMsgTitleTemplateSemanticEngineCode());//SimpleFieldAssign//sourceId:1464894_1_54169
                    }

                    /*D3执行下发公文给部门成员发消息(公共)[7969]   */
                    Assert.isNull(implementIssueOfficialDoSendDeptMemberMsgComReqDto.getOfficialDocumentId(), "D3修改公文-D3执行下发公文给部门成员发消息(公共)-公文ID不能为空", false);
                    Assert.isNull(implementIssueOfficialDoSendDeptMemberMsgComReqDto.getOfficialDocumentName(), "D3修改公文-D3执行下发公文给部门成员发消息(公共)-公文名称不能为空", false);
                    Assert.isNull(implementIssueOfficialDoSendDeptMemberMsgComReqDto.getMessageImportantLevel(), "D3修改公文-D3执行下发公文给部门成员发消息(公共)-消息重要紧急度层级不能为空", false);
                    Assert.isNull(implementIssueOfficialDoSendDeptMemberMsgComReqDto.getCooperateContentTypeCode(), "D3修改公文-D3执行下发公文给部门成员发消息(公共)-协同内容类型编码不能为空", false);
                    Assert.isNull(implementIssueOfficialDoSendDeptMemberMsgComReqDto.getCooperateContentId(), "D3修改公文-D3执行下发公文给部门成员发消息(公共)-协同内容ID不能为空", false);
                    Assert.isNull(implementIssueOfficialDoSendDeptMemberMsgComReqDto.getSurfaceContName(), "D3修改公文-D3执行下发公文给部门成员发消息(公共)-协同内容名称不能为空", false);
                    Assert.isNull(implementIssueOfficialDoSendDeptMemberMsgComReqDto.getSendMsgScene(), "D3修改公文-D3执行下发公文给部门成员发消息(公共)-发送消息场景不能为空", false);
                    Assert.isNull(implementIssueOfficialDoSendDeptMemberMsgComReqDto.getMessageTemplateCode(), "D3修改公文-D3执行下发公文给部门成员发消息(公共)-消息模板标识不能为空", false);
                    Assert.isNull(implementIssueOfficialDoSendDeptMemberMsgComReqDto.getMsgTitleTemplateSemanticEngineCode(), "D3修改公文-D3执行下发公文给部门成员发消息(公共)-消息标题模板引擎标识不能为空", false);
                    implementIssueOfficialDoSendDeptMemberMsgComRespDto = messageService.implementIssueOfficialDoSendDeptMemberMsgCom(implementIssueOfficialDoSendDeptMemberMsgComReqDto)/*vcase invoke isSameApp*/;


                }
            } else if ((queryOfficialDocumentDetailComRespDto != null && queryOfficialDocumentDetailComRespDto.getReceiveRange() != null && queryOfficialDocumentDetailComRespDto.getReceiveRange().equals("PERSON") && reqDto != null && reqDto.getOrgInductionRecordList() != null && reqDto.getOrgInductionRecordList().size() > 0)) {
                //elseif((D3-9查询公文详情(公共).接收范围 等于 个人 and D3修改公文.就职记录列表数据集条数 大于 0))  54167

                ImplementLoopSinglePersonSendMsgComRespDto implementLoopSinglePersonSendMsgComRespDto = null;
                if (queryOfficialDocumentDetailComRespDto != null && implementNotificationTypeMsgTempanAlyzeComRespDto != null) {
                    ImplementLoopSinglePersonSendMsgComReqDto implementLoopSinglePersonSendMsgComReqDto = new ImplementLoopSinglePersonSendMsgComReqDto();
                    implementLoopSinglePersonSendMsgComReqDto.setTableTypeCode("OMS_OFFICIAL_DOCUMENT");//sourceId:1381958_1_55913
                    implementLoopSinglePersonSendMsgComReqDto.setCooperateContentTypeCode("OMS_OFFICIAL_DOCUMENT");//sourceId:1381965_1_55913
                    if (reqDto != null) {
                        implementLoopSinglePersonSendMsgComReqDto.setOrgInductionRecordList(reqDto.getOrgInductionRecordList());//list-field-assign//sourceId:1381957_1_55913
                        implementLoopSinglePersonSendMsgComReqDto.setEntityId(reqDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1381959_1_55913
                        implementLoopSinglePersonSendMsgComReqDto.setCooperateContentId(reqDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1381966_1_55913
                    }
                    if (queryOfficialDocumentDetailComRespDto != null) {
                        implementLoopSinglePersonSendMsgComReqDto.setObjectName(queryOfficialDocumentDetailComRespDto.getOfficialDocumentName());//SimpleFieldAssign//sourceId:1381961_1_55913
                        implementLoopSinglePersonSendMsgComReqDto.setMessageImportantLevel(queryOfficialDocumentDetailComRespDto.getRemindLevel());//SimpleFieldAssign//sourceId:1381962_1_55913
                        implementLoopSinglePersonSendMsgComReqDto.setSurfaceContName(queryOfficialDocumentDetailComRespDto.getOfficialDocumentName());//SimpleFieldAssign//sourceId:1381967_1_55913
                    }
                    if (implementNotificationTypeMsgTempanAlyzeComRespDto != null) {
                        implementLoopSinglePersonSendMsgComReqDto.setMsgTitleTemplateSemanticEngineCode(implementNotificationTypeMsgTempanAlyzeComRespDto.getMsgTitleTemplateSemanticEngineCode());//SimpleFieldAssign//sourceId:1477095_1_55913
                        implementLoopSinglePersonSendMsgComReqDto.setMessageTemplateCode(implementNotificationTypeMsgTempanAlyzeComRespDto.getMessageTemplateCode());//SimpleFieldAssign//sourceId:1477090_1_55913
                        implementLoopSinglePersonSendMsgComReqDto.setSendMsgScene(implementNotificationTypeMsgTempanAlyzeComRespDto.getSendMsgScene());//SimpleFieldAssign//sourceId:1477091_1_55913
                    }

                    /*D3执行循环单人发消息(公共)[8086]   */
                    Assert.isNull(implementLoopSinglePersonSendMsgComReqDto.getTableTypeCode(), "D3修改公文-D3执行循环单人发消息(公共)-内容表类型编码不能为空", false);
                    Assert.isNull(implementLoopSinglePersonSendMsgComReqDto.getEntityId(), "D3修改公文-D3执行循环单人发消息(公共)-内容表主键ID不能为空", false);
                    Assert.isNull(implementLoopSinglePersonSendMsgComReqDto.getObjectName(), "D3修改公文-D3执行循环单人发消息(公共)-对象名称不能为空", false);
                    Assert.isNull(implementLoopSinglePersonSendMsgComReqDto.getMessageImportantLevel(), "D3修改公文-D3执行循环单人发消息(公共)-消息重要紧急度层级不能为空", false);
                    Assert.isNull(implementLoopSinglePersonSendMsgComReqDto.getCooperateContentTypeCode(), "D3修改公文-D3执行循环单人发消息(公共)-协同内容类型编码不能为空", false);
                    Assert.isNull(implementLoopSinglePersonSendMsgComReqDto.getCooperateContentId(), "D3修改公文-D3执行循环单人发消息(公共)-协同内容ID不能为空", false);
                    Assert.isNull(implementLoopSinglePersonSendMsgComReqDto.getSurfaceContName(), "D3修改公文-D3执行循环单人发消息(公共)-协同内容名称不能为空", false);
                    Assert.isNull(implementLoopSinglePersonSendMsgComReqDto.getMsgTitleTemplateSemanticEngineCode(), "D3修改公文-D3执行循环单人发消息(公共)-消息标题模板引擎标识不能为空", false);
                    Assert.isNull(implementLoopSinglePersonSendMsgComReqDto.getMessageTemplateCode(), "D3修改公文-D3执行循环单人发消息(公共)-消息模板标识不能为空", false);
                    Assert.isNull(implementLoopSinglePersonSendMsgComReqDto.getSendMsgScene(), "D3修改公文-D3执行循环单人发消息(公共)-发送消息场景不能为空", false);
                    implementLoopSinglePersonSendMsgComRespDto = messageService.implementLoopSinglePersonSendMsgCom(implementLoopSinglePersonSendMsgComReqDto)/*vcase invoke isSameApp*/;


                }
            }
            if ((queryOfficialDocumentDetailComRespDto != null && queryOfficialDocumentDetailComRespDto.getIsOpenWorkTask() != null && queryOfficialDocumentDetailComRespDto.getIsOpenWorkTask().equals("TRUE") && queryOfficialDocumentDetailComRespDto != null && queryOfficialDocumentDetailComRespDto.getAppointWorkTaskArrangeInductionId() != null)) {
                //if((D3-9查询公文详情(公共).是否开启工作任务 等于 是 and D3-9查询公文详情(公共).指定工作任务安排人就职记录ID 值不等于空 ))  54077

                QueryInductionDeptDetailComRespDto queryInductionDeptDetailComRespDto = null;
                QueryInductionDeptDetailComReqDto queryInductionDeptDetailComReqDto = new QueryInductionDeptDetailComReqDto();
                queryInductionDeptDetailComReqDto.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1477189_1_59125
                if (reqDto != null) {
                    queryInductionDeptDetailComReqDto.setInductionRecordId(reqDto.getAppointWorkTaskArrangeInductionId());//SimpleFieldAssign//sourceId:1477188_1_59125
                }

                /*D1查工作任务安排人身份人员ID[7829]   */
                Assert.isNull(queryInductionDeptDetailComReqDto.getInductionRecordId(), "D3修改公文-D1查工作任务安排人身份人员ID-就职记录ID不能为空", false);
                Assert.isNull(queryInductionDeptDetailComReqDto.getSpaceId(), "D3修改公文-D1查工作任务安排人身份人员ID-创建于空间ID不能为空", false);
                queryInductionDeptDetailComRespDto = inductionRecordService.queryInductionDeptDetailCom(queryInductionDeptDetailComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;


                ImplementSendTwoPersonConvMsgAndNumComRespDto implementSendTwoPersonConvMsgAndNumComRespDto = null;
                if (queryInductionDeptDetailComRespDto != null && queryOfficialDocumentDetailComRespDto != null) {
                    ImplementSendTwoPersonConvMsgAndNumComReqDto implementSendTwoPersonConvMsgAndNumComReqDto = new ImplementSendTwoPersonConvMsgAndNumComReqDto();
                    implementSendTwoPersonConvMsgAndNumComReqDto.setSendMsgScene("ISSUE_OFFICIAL_DOC_WORK_TASK_ARRANGE");//sourceId:1477147_1_59124
                    implementSendTwoPersonConvMsgAndNumComReqDto.setSurfaceCode("OMS_OFFICIAL_DOCUMENT");//sourceId:1477169_1_59124
                    implementSendTwoPersonConvMsgAndNumComReqDto.setTableTypeCode("OMS_OFFICIAL_DOCUMENT");//sourceId:1477157_1_59124
                    implementSendTwoPersonConvMsgAndNumComReqDto.setCooperateContentTypeCode("OMS_OFFICIAL_DOCUMENT");//sourceId:1477159_1_59124
                    implementSendTwoPersonConvMsgAndNumComReqDto.setIsHandle("FALSE");//sourceId:1477167_1_59124
                    implementSendTwoPersonConvMsgAndNumComReqDto.setHandleType("NEED_BUSINESS_OPERATION_HANDLING");//sourceId:1477168_1_59124
                    implementSendTwoPersonConvMsgAndNumComReqDto.setPlatformReplace("FALSE");//sourceId:1477171_1_59124
                    implementSendTwoPersonConvMsgAndNumComReqDto.setMessageImportantLevel(Long.valueOf(4));//CUSTOM_CONVENTION//sourceId:1477163_1_59124
                    implementSendTwoPersonConvMsgAndNumComReqDto.setMsgTitleTemplateSemanticEngineCode("ISSUE_OFFICIAL_DOC_WORK_TASK_ARRANGE_MSG_TITLE");//CUSTOM_CONVENTION//sourceId:1477151_1_59124
                    implementSendTwoPersonConvMsgAndNumComReqDto.setFirstFieldName("objectName");//CUSTOM_CONVENTION//sourceId:1477152_1_59124
                    implementSendTwoPersonConvMsgAndNumComReqDto.setComNumField(Long.valueOf(2));//CUSTOM_CONVENTION//sourceId:1477164_1_59124
                    implementSendTwoPersonConvMsgAndNumComReqDto.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1477149_1_59124
                    implementSendTwoPersonConvMsgAndNumComReqDto.setAppId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecAppId());//CURRENT_APPID//sourceId:1477150_1_59124
                    if (queryInductionDeptDetailComRespDto != null) {
                        implementSendTwoPersonConvMsgAndNumComReqDto.setReceiveOriginalRoleMemberId(queryInductionDeptDetailComRespDto.getOriginalRoleMemberId());//SimpleFieldAssign//sourceId:1477146_1_59124
                    }
                    if (reqDto != null) {
                        implementSendTwoPersonConvMsgAndNumComReqDto.setEntityId(reqDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1477170_1_59124
                        implementSendTwoPersonConvMsgAndNumComReqDto.setTableContentEntityId(reqDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1547110_1_59124
                        implementSendTwoPersonConvMsgAndNumComReqDto.setCooperateContentId(reqDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1477160_1_59124
                    }
                    if (queryOfficialDocumentDetailComRespDto != null) {
                        implementSendTwoPersonConvMsgAndNumComReqDto.setSurfaceContName(queryOfficialDocumentDetailComRespDto.getOfficialDocumentName());//SimpleFieldAssign//sourceId:1477161_1_59124
                        implementSendTwoPersonConvMsgAndNumComReqDto.setFirstFieldValue(queryOfficialDocumentDetailComRespDto.getOfficialDocumentName());//SimpleFieldAssign//sourceId:1477153_1_59124
                    }

                    /*D3执行发两人会话消息及数量(公共)[8262]   */
                    Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getSendMsgScene(), "D3修改公文-D3执行发两人会话消息及数量(公共)-发送消息场景不能为空", false);
                    Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getReceiveOriginalRoleMemberId(), "D3修改公文-D3执行发两人会话消息及数量(公共)-接收方身份人员ID不能为空", false);
                    Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getSurfaceCode(), "D3修改公文-D3执行发两人会话消息及数量(公共)-归属内容类型编码不能为空", false);
                    Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getEntityId(), "D3修改公文-D3执行发两人会话消息及数量(公共)-归属内容ID不能为空", false);
                    Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getTableTypeCode(), "D3修改公文-D3执行发两人会话消息及数量(公共)-冗余内容表类型编码不能为空", false);
                    Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getTableContentEntityId(), "D3修改公文-D3执行发两人会话消息及数量(公共)-冗余内容表主键ID不能为空", false);
                    Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getCooperateContentTypeCode(), "D3修改公文-D3执行发两人会话消息及数量(公共)-协同内容类型编码不能为空", false);
                    Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getCooperateContentId(), "D3修改公文-D3执行发两人会话消息及数量(公共)-协同内容ID不能为空", false);
                    Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getSurfaceContName(), "D3修改公文-D3执行发两人会话消息及数量(公共)-协同内容名称不能为空", false);
                    Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getIsHandle(), "D3修改公文-D3执行发两人会话消息及数量(公共)-是否已处理不能为空", false);
                    Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getHandleType(), "D3修改公文-D3执行发两人会话消息及数量(公共)-处理类型不能为空", false);
                    Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getPlatformReplace(), "D3修改公文-D3执行发两人会话消息及数量(公共)-是否平台代操作不能为空", false);
                    Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getMessageImportantLevel(), "D3修改公文-D3执行发两人会话消息及数量(公共)-消息重要紧急度层级不能为空", false);
                    Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getMsgTitleTemplateSemanticEngineCode(), "D3修改公文-D3执行发两人会话消息及数量(公共)-消息标题模板引擎标识不能为空", false);
                    Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getMessageTemplateCode(), "D3修改公文-D3执行发两人会话消息及数量(公共)-消息模板标识不能为空", false);
                    Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getFirstFieldName(), "D3修改公文-D3执行发两人会话消息及数量(公共)-第一个字段字段名不能为空", false);
                    Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getFirstFieldValue(), "D3修改公文-D3执行发两人会话消息及数量(公共)-第一个字段字段值不能为空", false);
                    Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getComNumField(), "D3修改公文-D3执行发两人会话消息及数量(公共)-通用数值字段（整数型）不能为空", false);
                    Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getSpaceId(), "D3修改公文-D3执行发两人会话消息及数量(公共)-创建于空间ID不能为空", false);
                    Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getAppId(), "D3修改公文-D3执行发两人会话消息及数量(公共)-创建于联盟应用ID不能为空", false);
                    implementSendTwoPersonConvMsgAndNumComRespDto = messageService.implementSendTwoPersonConvMsgAndNumCom(implementSendTwoPersonConvMsgAndNumComReqDto)/*vcase invoke isSameApp*/;


                }
            }
        }
//virtualUsage D2查平台文件存储根路径配置答案（公共）  71632
        QueryConfItemMatchAnswerDetailComRespDto queryConfItemMatchAnswerDetailComRespDto = null;
        QueryConfItemMatchAnswerDetailComReqDto queryConfItemMatchAnswerDetailComReqDto = new QueryConfItemMatchAnswerDetailComReqDto();
        queryConfItemMatchAnswerDetailComReqDto.setConfItemCode("FILE_STORAGE_ROOT_PATH");//CUSTOM_CONVENTION//sourceId:1935923_1_71632
        queryConfItemMatchAnswerDetailComReqDto.setConfSchemeCode("COM_CONF_SCHEME");//CUSTOM_CONVENTION//sourceId:1935924_1_71632
        queryConfItemMatchAnswerDetailComReqDto.setIsPlatData("TRUE");//sourceId:1935925_1_71632

        /*D2查平台文件存储根路径配置答案（公共）[2486]   */
        Assert.isNull(queryConfItemMatchAnswerDetailComReqDto.getConfItemCode(), "D3修改公文-D2查平台文件存储根路径配置答案（公共）-配置项标识不能为空", false);
        Assert.isNull(queryConfItemMatchAnswerDetailComReqDto.getConfSchemeCode(), "D3修改公文-D2查平台文件存储根路径配置答案（公共）-配置方案标识不能为空", false);
        Assert.isNull(queryConfItemMatchAnswerDetailComReqDto.getIsPlatData(), "D3修改公文-D2查平台文件存储根路径配置答案（公共）-是否标准答案不能为空", false);
        queryConfItemMatchAnswerDetailComRespDto = confSchemeService.queryConfItemMatchAnswerDetailCom(queryConfItemMatchAnswerDetailComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;


//virtualUsage D2执行清理个人用户无效文件(公共)  71633
        ImplementClearMemberInvalidDocComRespDto implementClearMemberInvalidDocComRespDto = null;
        if (queryConfItemMatchAnswerDetailComRespDto != null) {
            ImplementClearMemberInvalidDocComReqDto implementClearMemberInvalidDocComReqDto = new ImplementClearMemberInvalidDocComReqDto();
            implementClearMemberInvalidDocComReqDto.setIsCleanPersonalInvalidDocument("TRUE");//sourceId:1935186_1_71633
            implementClearMemberInvalidDocComReqDto.setUserId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecUserId());//CURRENT_USERID//sourceId:1935184_1_71633
            if (queryConfItemMatchAnswerDetailComRespDto != null) {
                implementClearMemberInvalidDocComReqDto.setFileStorageRootPath(queryConfItemMatchAnswerDetailComRespDto.getEndValue());//SimpleFieldAssign//sourceId:1935185_1_71633
            }

            /*D2执行清理个人用户无效文件(公共)[8792]   */
            Assert.isNull(implementClearMemberInvalidDocComReqDto.getIsCleanPersonalInvalidDocument(), "D3修改公文-D2执行清理个人用户无效文件(公共)-是否清理个人无效文档不能为空", false);
            Assert.isNull(implementClearMemberInvalidDocComReqDto.getUserId(), "D3修改公文-D2执行清理个人用户无效文件(公共)-归属个人账号不能为空", false);
            Assert.isNull(implementClearMemberInvalidDocComReqDto.getFileStorageRootPath(), "D3修改公文-D2执行清理个人用户无效文件(公共)-文件存储根路径不能为空", false);
            implementClearMemberInvalidDocComRespDto = unstructuredDataService.implementClearMemberInvalidDocCom(implementClearMemberInvalidDocComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;


        }
        UpdateOfficialDocumentRespDto retData = new UpdateOfficialDocumentRespDto();


        return retData;
    }

    /**
     * D3-9删除公文(公共)[7939]
     * gen by moon at 11/12/2023, 10:33:39 PM
     */
    @Trace(operationName = "D3-9删除公文(公共)")
    @Tags({@Tag(key = "参数", value = "arg[0]"),
            @Tag(key = "返回值", value = "returnedObj")})
    @Transactional(rollbackFor = Exception.class)
    @Override
    public DeleteOfficialDocumentComRespDto deleteOfficialDocumentCom(DeleteOfficialDocumentComReqDto reqDto) {


        //步骤0: 3-9-01删除公文 - deleteOfficialDocument
        boolean bOOLEAN;
        String string = new String();
        if (reqDto != null) {
            string = reqDto.getOfficialDocumentId();
            ;//SimpleFieldAssign//sourceId:1312452_1
        }

        /*3-9-01删除公文[7940]   */
        Assert.isNull(string, "D3-9删除公文(公共)-3-9-01删除公文-公文ID不能为空", false);
        bOOLEAN = mOmsOfficialDocumentService.deleteOfficialDocument(string)/*vcase invoke 本地 method 方法调用;*/;


        DeleteOfficialDocumentComRespDto retData = new DeleteOfficialDocumentComRespDto();


        return retData;
    }

    /**
     * D3-9查询公文详情(公共)[7930]
     * gen by moon at 12/16/2023, 8:36:54 PM
     */
    @Trace(operationName = "D3-9查询公文详情(公共)")
    @Tags({@Tag(key = "参数", value = "arg[0]"),
            @Tag(key = "返回值", value = "returnedObj")})
    @Transactional(rollbackFor = Exception.class)
    @Override
    public QueryOfficialDocumentDetailComRespDto queryOfficialDocumentDetailCom(QueryOfficialDocumentDetailComReqDto reqDto) {


        OmsOfficialDocument omsOfficialDocument_1 = null;
//步骤0: 3-9-01查询公文详情 - queryOfficialDocumentDetail
        OmsOfficialDocument omsOfficialDocument = null;
        QueryOfficialDocumentDetailReq queryOfficialDocumentDetailReq = new QueryOfficialDocumentDetailReq();
        if (reqDto != null) {
            queryOfficialDocumentDetailReq.setOfficialDocumentId(reqDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1311634_1
            queryOfficialDocumentDetailReq.setOfficialDocumentName(reqDto.getOfficialDocumentName());//SimpleFieldAssign//sourceId:1311635_1
            queryOfficialDocumentDetailReq.setOfficialDocumentNum(reqDto.getOfficialDocumentNum());//SimpleFieldAssign//sourceId:1311636_1
            queryOfficialDocumentDetailReq.setReceiveInductionId(reqDto.getReceiveInductionId());//SimpleFieldAssign//sourceId:1311637_1
            queryOfficialDocumentDetailReq.setArrangeWorkTaskId(reqDto.getArrangeWorkTaskId());//SimpleFieldAssign//sourceId:1345986_1
            queryOfficialDocumentDetailReq.setIsArchive(reqDto.getIsArchive());//SimpleFieldAssign//sourceId:1311641_1
            queryOfficialDocumentDetailReq.setSubjectLifeCycle(reqDto.getSubjectLifeCycle());//SimpleFieldAssign//sourceId:1311642_1
            queryOfficialDocumentDetailReq.setSpaceId(reqDto.getSpaceId());//SimpleFieldAssign//sourceId:1311638_1
        }

        /*3-9-01查询公文详情[7929]   */
        Assert.isNull(queryOfficialDocumentDetailReq.getSpaceId(), "D3-9查询公文详情(公共)-3-9-01查询公文详情-创建于空间ID不能为空", false);
        omsOfficialDocument = mOmsOfficialDocumentService.queryOfficialDocumentDetail(queryOfficialDocumentDetailReq)/*vcase invoke 本地 method 方法调用;*/;


        omsOfficialDocument_1 = omsOfficialDocument;

        QueryOfficialDocumentDetailComRespDto retData = new QueryOfficialDocumentDetailComRespDto();
        if (omsOfficialDocument_1 != null) {
            retData.setOfficialDocumentId(omsOfficialDocument_1.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1311673_1
            retData.setOfficialDocumentName(omsOfficialDocument_1.getOfficialDocumentName());//SimpleFieldAssign//sourceId:1311674_1
            retData.setOfficialDocumentNum(omsOfficialDocument_1.getOfficialDocumentNum());//SimpleFieldAssign//sourceId:1311675_1
            retData.setNotificationDescription(omsOfficialDocument_1.getNotificationDescription());//SimpleFieldAssign//sourceId:1420042_1
            retData.setOfficialDocumentFileAddress(omsOfficialDocument_1.getOfficialDocumentFileAddress());//SimpleFieldAssign//sourceId:1311676_1
            retData.setAnnexAddress(omsOfficialDocument_1.getAnnexAddress());//SimpleFieldAssign//sourceId:1311677_1
            retData.setReceiveRange(omsOfficialDocument_1.getReceiveRange());//SimpleFieldAssign//sourceId:1311678_1
            retData.setNotificationType(omsOfficialDocument_1.getNotificationType());//SimpleFieldAssign//sourceId:1418231_1
            retData.setReceiveInductionId(omsOfficialDocument_1.getReceiveInductionId());//SimpleFieldAssign//sourceId:1311679_1
            retData.setRemindLevel(omsOfficialDocument_1.getRemindLevel());//SimpleFieldAssign//sourceId:1311680_1
            retData.setIsOpenWorkTask(omsOfficialDocument_1.getIsOpenWorkTask());//SimpleFieldAssign//sourceId:1311681_1
            retData.setWorkTaskIsArrange(omsOfficialDocument_1.getWorkTaskIsArrange());//SimpleFieldAssign//sourceId:1311682_1
            retData.setAppointWorkTaskArrangeInductionId(omsOfficialDocument_1.getAppointWorkTaskArrangeInductionId());//SimpleFieldAssign//sourceId:1311683_1
            retData.setArrangeWorkTaskId(omsOfficialDocument_1.getArrangeWorkTaskId());//SimpleFieldAssign//sourceId:1317445_1
            retData.setArrangeWorkTaskTypeCode(omsOfficialDocument_1.getArrangeWorkTaskTypeCode());//SimpleFieldAssign//sourceId:1317446_1
            retData.setSubjectLifeCycle(omsOfficialDocument_1.getSubjectLifeCycle());//SimpleFieldAssign//sourceId:1311684_1
            retData.setIsArchive(omsOfficialDocument_1.getIsArchive());//SimpleFieldAssign//sourceId:1311685_1
            retData.setOperationInductionId(omsOfficialDocument_1.getOperationInductionId());//SimpleFieldAssign//sourceId:1311686_1
            retData.setCreateInductionId(omsOfficialDocument_1.getCreateInductionId());//SimpleFieldAssign//sourceId:1311687_1
            retData.setReleaseInductionId(omsOfficialDocument_1.getReleaseInductionId());//SimpleFieldAssign//sourceId:1311688_1
            retData.setArchiveInductionId(omsOfficialDocument_1.getArchiveInductionId());//SimpleFieldAssign//sourceId:1311689_1
            retData.setOperateTime(omsOfficialDocument_1.getOperateTime());//SimpleFieldAssign//sourceId:1311690_1
            retData.setCreateTime(omsOfficialDocument_1.getCreateTime());//SimpleFieldAssign//sourceId:1311691_1
            retData.setReleaseTime(omsOfficialDocument_1.getReleaseTime());//SimpleFieldAssign//sourceId:1311692_1
            retData.setArchiveTime(omsOfficialDocument_1.getArchiveTime());//SimpleFieldAssign//sourceId:1311693_1
            retData.setSpaceId(omsOfficialDocument_1.getSpaceId());//SimpleFieldAssign//sourceId:1311694_1
            retData.setAppId(omsOfficialDocument_1.getAppId());//SimpleFieldAssign//sourceId:1311695_1
        }


        return retData;
    }

    /**
     * D3-9查询相同公文列表(公共)[7925]
     * gen by moon at 12/16/2023, 1:44:33 PM
     */
    @Trace(operationName = "D3-9查询相同公文列表(公共)")
    @Tags({@Tag(key = "参数", value = "arg[0]"),
            @Tag(key = "返回值", value = "returnedObj")})
    @Transactional(rollbackFor = Exception.class)
    @Override
    public QueryAlikeOfficialDocumentListComRespDto queryAlikeOfficialDocumentListCom(QueryAlikeOfficialDocumentListComReqDto reqDto) {


        List<OmsOfficialDocument> listOmsOfficialDocument_1 = new ArrayList<>();
//步骤0: 3-9-01查询公文列表 - queryOfficialDocumentList
        List<OmsOfficialDocument> listOmsOfficialDocument = new ArrayList<>();
        QueryOfficialDocumentListReq queryOfficialDocumentListReq = new QueryOfficialDocumentListReq();
        if (reqDto != null) {
            queryOfficialDocumentListReq.setOfficialDocumentName(reqDto.getOfficialDocumentName());//SimpleFieldAssign//sourceId:1311546_1
            queryOfficialDocumentListReq.setOfficialDocumentNum(reqDto.getOfficialDocumentNum());//SimpleFieldAssign//sourceId:1311551_1
            queryOfficialDocumentListReq.setNotificationType(reqDto.getNotificationType());//SimpleFieldAssign//sourceId:1416396_1
            queryOfficialDocumentListReq.setIssueSubjectId(reqDto.getIssueSubjectId());//SimpleFieldAssign//sourceId:1420004_1
            queryOfficialDocumentListReq.setIsArchive(reqDto.getIsArchive());//SimpleFieldAssign//sourceId:1311547_1
            queryOfficialDocumentListReq.setSubjectLifeCycle(reqDto.getSubjectLifeCycle());//SimpleFieldAssign//sourceId:1311552_1
            queryOfficialDocumentListReq.setSpaceId(reqDto.getSpaceId());//SimpleFieldAssign//sourceId:1311548_1
        }

        /*3-9-01查询公文列表[7926]   */
        Assert.isNull(queryOfficialDocumentListReq.getSpaceId(), "D3-9查询相同公文列表(公共)-3-9-01查询公文列表-创建于空间ID不能为空", false);
        listOmsOfficialDocument = mOmsOfficialDocumentService.queryOfficialDocumentList(queryOfficialDocumentListReq)/*vcase invoke 本地 method 方法调用;*/;


        listOmsOfficialDocument_1 = listOmsOfficialDocument;

        QueryAlikeOfficialDocumentListComRespDto retData = new QueryAlikeOfficialDocumentListComRespDto();
        retData.setOfficialDocumentList(listOmsOfficialDocument_1.stream().map(item -> BeanUtil.toBean(item, OfficialDocumentDto.class)).collect(Collectors.toList()));//objList-to-objLists//sourceId:1311558_1


        return retData;
    }

    /**
     * D3-9新增公文主体(公共)[7920]
     * gen by moon at 12/16/2023, 8:36:40 PM
     */
    @Trace(operationName = "D3-9新增公文主体(公共)")
    @Tags({@Tag(key = "参数", value = "arg[0]"),
            @Tag(key = "返回值", value = "returnedObj")})
    @Transactional(rollbackFor = Exception.class)
    @Override
    public AddOfficialDocumentBodyComRespDto addOfficialDocumentBodyCom(AddOfficialDocumentBodyComReqDto reqDto) {


        String string_1 = null;
//步骤0: 3-9-01新增公文 - addOfficialDocument
        String string = null;
        OmsOfficialDocument omsOfficialDocument = new OmsOfficialDocument();
        if (reqDto != null) {
            omsOfficialDocument.setOfficialDocumentName(reqDto.getOfficialDocumentName());//SimpleFieldAssign//sourceId:1311418_1
            omsOfficialDocument.setOfficialDocumentNum(reqDto.getOfficialDocumentNum());//SimpleFieldAssign//sourceId:1311419_1
            omsOfficialDocument.setNotificationDescription(reqDto.getNotificationDescription());//SimpleFieldAssign//sourceId:1420035_1
            omsOfficialDocument.setReceiveRange(reqDto.getReceiveRange());//SimpleFieldAssign//sourceId:1311422_1
            omsOfficialDocument.setNotificationType(reqDto.getNotificationType());//SimpleFieldAssign//sourceId:1416387_1
            omsOfficialDocument.setRemindLevel(reqDto.getRemindLevel());//SimpleFieldAssign//sourceId:1311424_1
            omsOfficialDocument.setIsOpenWorkTask(reqDto.getIsOpenWorkTask());//SimpleFieldAssign//sourceId:1311425_1
            omsOfficialDocument.setWorkTaskIsArrange(reqDto.getWorkTaskIsArrange());//SimpleFieldAssign//sourceId:1311426_1
            omsOfficialDocument.setAppointWorkTaskArrangeInductionId(reqDto.getAppointWorkTaskArrangeInductionId());//SimpleFieldAssign//sourceId:1311427_1
            omsOfficialDocument.setIssueSubjectId(reqDto.getIssueSubjectId());//SimpleFieldAssign//sourceId:1420009_1
            omsOfficialDocument.setIssueSubjectTypeCode(reqDto.getIssueSubjectTypeCode());//SimpleFieldAssign//sourceId:1420010_1
            omsOfficialDocument.setSubjectLifeCycle(reqDto.getSubjectLifeCycle());//SimpleFieldAssign//sourceId:1311428_1
        }

        /*3-9-01新增公文[7919]   */
        Assert.isNull(omsOfficialDocument.getOfficialDocumentName(), "D3-9新增公文主体(公共)-3-9-01新增公文-公文名称不能为空", false);
        Assert.isNull(omsOfficialDocument.getReceiveRange(), "D3-9新增公文主体(公共)-3-9-01新增公文-接收范围不能为空", false);
        Assert.isNull(omsOfficialDocument.getNotificationType(), "D3-9新增公文主体(公共)-3-9-01新增公文-通知类型不能为空", false);
        Assert.isNull(omsOfficialDocument.getIsOpenWorkTask(), "D3-9新增公文主体(公共)-3-9-01新增公文-是否开启工作任务不能为空", false);
        Assert.isNull(omsOfficialDocument.getSubjectLifeCycle(), "D3-9新增公文主体(公共)-3-9-01新增公文-主体生命周期不能为空", false);
        string = mOmsOfficialDocumentService.addOfficialDocument(omsOfficialDocument)/*vcase invoke 本地 method 方法调用;*/;


        string_1 = string;

        AddOfficialDocumentBodyComRespDto retData = new AddOfficialDocumentBodyComRespDto();
        if (string_1 != null) {
            retData.setOfficialDocumentId(string_1);//SimpleFieldAssign//sourceId:1311441_1
        }


        return retData;
    }

    /**
     * D3新增公文[7921]
     * gen by moon at 7/18/2024, 6:34:29 PM
     */
    @Trace(operationName = "D3新增公文")
    @Tags({@Tag(key = "参数", value = "arg[0]"),
            @Tag(key = "返回值", value = "returnedObj")})
    @Transactional(rollbackFor = Exception.class)
    @Override
    public AddOfficialDocumentRespDto addOfficialDocument(AddOfficialDocumentReqDto reqDto) {


        AddOfficialDocumentBodyComRespDto addOfficialDocumentBodyComRespDto_1 = null;
//virtualUsage D3-9查询相同公文列表(公共)  53497
        QueryAlikeOfficialDocumentListComRespDto queryAlikeOfficialDocumentListComRespDto = null;
        QueryAlikeOfficialDocumentListComReqDto queryAlikeOfficialDocumentListComReqDto = new QueryAlikeOfficialDocumentListComReqDto();
        queryAlikeOfficialDocumentListComReqDto.setIsArchive("FALSE");//sourceId:1311565_1_53497
        queryAlikeOfficialDocumentListComReqDto.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1311563_1_53497
        if (reqDto != null) {
            queryAlikeOfficialDocumentListComReqDto.setOfficialDocumentName(reqDto.getOfficialDocumentName());//SimpleFieldAssign//sourceId:1311559_1_53497
            queryAlikeOfficialDocumentListComReqDto.setNotificationType(reqDto.getNotificationType());//SimpleFieldAssign//sourceId:1416398_1_53497
            queryAlikeOfficialDocumentListComReqDto.setIssueSubjectId(reqDto.getIssueSubjectId());//SimpleFieldAssign//sourceId:1420006_1_53497
        }

        /*D3-9查询相同公文列表(公共)[7925]   */
        Assert.isNull(queryAlikeOfficialDocumentListComReqDto.getOfficialDocumentName(), "D3新增公文-D3-9查询相同公文列表(公共)-公文名称不能为空", false);
        Assert.isNull(queryAlikeOfficialDocumentListComReqDto.getNotificationType(), "D3新增公文-D3-9查询相同公文列表(公共)-通知类型不能为空", false);
        Assert.isNull(queryAlikeOfficialDocumentListComReqDto.getIsArchive(), "D3新增公文-D3-9查询相同公文列表(公共)-是否存档不能为空", false);
        Assert.isNull(queryAlikeOfficialDocumentListComReqDto.getSpaceId(), "D3新增公文-D3-9查询相同公文列表(公共)-创建于空间ID不能为空", false);
        queryAlikeOfficialDocumentListComRespDto = queryAlikeOfficialDocumentListCom(queryAlikeOfficialDocumentListComReqDto)/*vcase invoke 同服务,同domain*/;


        if ((queryAlikeOfficialDocumentListComRespDto != null && queryAlikeOfficialDocumentListComRespDto.getOfficialDocumentList() != null && queryAlikeOfficialDocumentListComRespDto.getOfficialDocumentList().size() > 0)) {
            //if(D3-9查询相同公文列表(公共).公文列表数据集条数 大于 0)  53498

//异常结束 53499
            throw new BizException("C00116", "对不起！已存在~！", false);
        } else if ((queryAlikeOfficialDocumentListComRespDto != null && queryAlikeOfficialDocumentListComRespDto.getOfficialDocumentList() != null && queryAlikeOfficialDocumentListComRespDto.getOfficialDocumentList().size() == 0)) {
            //elseif(D3-9查询相同公文列表(公共).公文列表数据集条数 等于 0)  53500

            AddOfficialDocumentBodyComRespDto addOfficialDocumentBodyComRespDto = null;
            AddOfficialDocumentBodyComReqDto addOfficialDocumentBodyComReqDto = new AddOfficialDocumentBodyComReqDto();
            if (reqDto != null) {
                addOfficialDocumentBodyComReqDto.setOfficialDocumentName(reqDto.getOfficialDocumentName());//SimpleFieldAssign//sourceId:1311442_1_53501
                addOfficialDocumentBodyComReqDto.setOfficialDocumentNum(reqDto.getOfficialDocumentNum());//SimpleFieldAssign//sourceId:1311443_1_53501
                addOfficialDocumentBodyComReqDto.setNotificationDescription(reqDto.getNotificationDescription());//SimpleFieldAssign//sourceId:1420037_1_53501
                addOfficialDocumentBodyComReqDto.setReceiveRange(reqDto.getReceiveRange());//SimpleFieldAssign//sourceId:1311446_1_53501
                addOfficialDocumentBodyComReqDto.setRemindLevel(reqDto.getRemindLevel());//SimpleFieldAssign//sourceId:1311448_1_53501
                addOfficialDocumentBodyComReqDto.setNotificationType(reqDto.getNotificationType());//SimpleFieldAssign//sourceId:1416389_1_53501
                addOfficialDocumentBodyComReqDto.setIsOpenWorkTask(reqDto.getIsOpenWorkTask());//SimpleFieldAssign//sourceId:1311449_1_53501
                addOfficialDocumentBodyComReqDto.setAppointWorkTaskArrangeInductionId(reqDto.getAppointWorkTaskArrangeInductionId());//SimpleFieldAssign//sourceId:1311451_1_53501
                addOfficialDocumentBodyComReqDto.setIssueSubjectId(reqDto.getIssueSubjectId());//SimpleFieldAssign//sourceId:1420013_1_53501
                addOfficialDocumentBodyComReqDto.setIssueSubjectTypeCode(reqDto.getIssueSubjectTypeCode());//SimpleFieldAssign//sourceId:1420014_1_53501
                addOfficialDocumentBodyComReqDto.setSubjectLifeCycle(reqDto.getSubjectLifeCycle());//SimpleFieldAssign//sourceId:1311452_1_53501
            }

            /*D3-9新增公文主体(公共)[7920]   */
            Assert.isNull(addOfficialDocumentBodyComReqDto.getOfficialDocumentName(), "D3新增公文-D3-9新增公文主体(公共)-公文名称不能为空", false);
            Assert.isNull(addOfficialDocumentBodyComReqDto.getReceiveRange(), "D3新增公文-D3-9新增公文主体(公共)-接收范围不能为空", false);
            Assert.isNull(addOfficialDocumentBodyComReqDto.getNotificationType(), "D3新增公文-D3-9新增公文主体(公共)-通知类型不能为空", false);
            Assert.isNull(addOfficialDocumentBodyComReqDto.getIsOpenWorkTask(), "D3新增公文-D3-9新增公文主体(公共)-是否开启工作任务不能为空", false);
            Assert.isNull(addOfficialDocumentBodyComReqDto.getSubjectLifeCycle(), "D3新增公文-D3-9新增公文主体(公共)-主体生命周期不能为空", false);
            addOfficialDocumentBodyComRespDto = addOfficialDocumentBodyCom(addOfficialDocumentBodyComReqDto)/*vcase invoke 同服务,同domain*/;


            addOfficialDocumentBodyComRespDto_1 = addOfficialDocumentBodyComRespDto;
            ImplementSeparateAddOrDeleteDocListComRespDto implementSeparateAddOrDeleteDocListComRespDto = null;
            if (addOfficialDocumentBodyComRespDto != null) {
                ImplementSeparateAddOrDeleteDocListComReqDto implementSeparateAddOrDeleteDocListComReqDto = new ImplementSeparateAddOrDeleteDocListComReqDto();
                implementSeparateAddOrDeleteDocListComReqDto.setIsCleanPersonalInvalidDocument("FALSE");//sourceId:1934774_1_69745
                implementSeparateAddOrDeleteDocListComReqDto.setDocUseSceneCode("WORK_TASKS");//sourceId:1854864_1_69745
                implementSeparateAddOrDeleteDocListComReqDto.setDocUseType("OFFICIAL_DOCUMENT_ANNEX");//sourceId:1854865_1_69745
                implementSeparateAddOrDeleteDocListComReqDto.setIsResult("FALSE");//sourceId:1859364_1_69745
                implementSeparateAddOrDeleteDocListComReqDto.setOwnTableTypeCode("OMS_OFFICIAL_DOCUMENT");//sourceId:1854867_1_69745
                implementSeparateAddOrDeleteDocListComReqDto.setUserId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecUserId());//CURRENT_USERID//sourceId:1854873_1_69745
                implementSeparateAddOrDeleteDocListComReqDto.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1854862_1_69745
                if (reqDto != null && reqDto.getDocumentList() != null && !CollectionUtil.isEmpty(reqDto.getDocumentList())) {
                    implementSeparateAddOrDeleteDocListComReqDto.setDocumentList(reqDto.getDocumentList().stream().map(item -> BeanUtil.toBean(item, com.wicket.okrcomponent.integration.dto.DocumentDto.class)).collect(Collectors.toList()));//objList-to-objLists//sourceId:1854863_1_69745
                }
                if (addOfficialDocumentBodyComRespDto != null) {
                    implementSeparateAddOrDeleteDocListComReqDto.setOwnEntityId(addOfficialDocumentBodyComRespDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1854861_1_69745
                }

                /*D2新增或删除公文附件文档关系(公共)[8783]   */
                Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto.getIsCleanPersonalInvalidDocument(), "D3新增公文-D2新增或删除公文附件文档关系(公共)-是否清理个人无效文档不能为空", false);
                Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto.getDocUseSceneCode(), "D3新增公文-D2新增或删除公文附件文档关系(公共)-文档应用业务场景不能为空", false);
                Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto.getDocUseType(), "D3新增公文-D2新增或删除公文附件文档关系(公共)-文档用途类型不能为空", false);
                Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto.getIsResult(), "D3新增公文-D2新增或删除公文附件文档关系(公共)-冗余是否结果文档不能为空", false);
                Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto.getOwnEntityId(), "D3新增公文-D2新增或删除公文附件文档关系(公共)-归属内容表主键ID不能为空", false);
                Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto.getOwnTableTypeCode(), "D3新增公文-D2新增或删除公文附件文档关系(公共)-归属内容表类型编码不能为空", false);
                Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto.getUserId(), "D3新增公文-D2新增或删除公文附件文档关系(公共)-归属个人账号不能为空", false);
                Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto.getSpaceId(), "D3新增公文-D2新增或删除公文附件文档关系(公共)-创建于空间ID不能为空", false);
                implementSeparateAddOrDeleteDocListComRespDto = unstructuredDataService.implementSeparateAddOrDeleteDocListCom(implementSeparateAddOrDeleteDocListComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;


            }
            ImplementDataAppointFormatShiftTextComRespDto implementDataAppointFormatShiftTextComRespDto = null;
            ImplementDataAppointFormatShiftTextComReqDto implementDataAppointFormatShiftTextComReqDto = new ImplementDataAppointFormatShiftTextComReqDto();
            implementDataAppointFormatShiftTextComReqDto.setCustomField1("；");//CUSTOM_CONVENTION//sourceId:1313461_1_53623
            if (reqDto != null && reqDto.getDocumentList() != null && !CollectionUtil.isEmpty(reqDto.getDocumentList())) {
                implementDataAppointFormatShiftTextComReqDto.setDataAppointFormatShiftTextList(reqDto.getDocumentList().stream().map(item -> item.getFileRelativePathAccess())
                        .collect(Collectors.toList()));/*list-to-strings*///sourceId:1313460_1_53623
            }

            /*D2附件相对路径数据集转单字段[7515]   */
            Assert.isNull(implementDataAppointFormatShiftTextComReqDto.getCustomField1(), "D3新增公文-D2附件相对路径数据集转单字段-自定义字段1不能为空", false);
            implementDataAppointFormatShiftTextComRespDto = interfaceModeService.implementDataAppointFormatShiftTextCom(implementDataAppointFormatShiftTextComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;


            if ((reqDto != null && reqDto.getOfficialDocumentUnstructuredDataId() != null)) {
                //if(D3新增公文.公文文档ID 值不等于空 )  53616

                ImplementSingleMultipleFieldSetDataEntryComRespDto implementSingleMultipleFieldSetDataEntryComRespDto = null;
                ImplementSingleMultipleFieldSetDataEntryComReqDto implementSingleMultipleFieldSetDataEntryComReqDto = new ImplementSingleMultipleFieldSetDataEntryComReqDto();
                if (reqDto != null) {
                    implementSingleMultipleFieldSetDataEntryComReqDto.setCustomField1(reqDto.getOfficialDocumentUnstructuredDataId());//SimpleFieldAssign//sourceId:1856422_1_69759
                    implementSingleMultipleFieldSetDataEntryComReqDto.setCustomField2(reqDto.getPostfix());//SimpleFieldAssign//sourceId:1856423_1_69759
                    implementSingleMultipleFieldSetDataEntryComReqDto.setCustomField3(reqDto.getFileRelativePathAccess());//SimpleFieldAssign//sourceId:1856424_1_69759
                    implementSingleMultipleFieldSetDataEntryComReqDto.setCustomField4(reqDto.getSourceRelationshipId());//SimpleFieldAssign//sourceId:1856425_1_69759
                    implementSingleMultipleFieldSetDataEntryComReqDto.setCustomField5(reqDto.getRelationshipType());//SimpleFieldAssign//sourceId:1856426_1_69759
                    implementSingleMultipleFieldSetDataEntryComReqDto.setCustomField6(reqDto.getIsNetworkReference());//SimpleFieldAssign//sourceId:1856427_1_69759
                }

                /*D2执行单条多字段转数据集(公共)[9762]   */
                Assert.isNull(implementSingleMultipleFieldSetDataEntryComReqDto.getCustomField1(), "D3新增公文-D2执行单条多字段转数据集(公共)-自定义字段1不能为空", false);
                Assert.isNull(implementSingleMultipleFieldSetDataEntryComReqDto.getCustomField2(), "D3新增公文-D2执行单条多字段转数据集(公共)-自定义字段2不能为空", false);
                Assert.isNull(implementSingleMultipleFieldSetDataEntryComReqDto.getCustomField3(), "D3新增公文-D2执行单条多字段转数据集(公共)-自定义字段3不能为空", false);
                implementSingleMultipleFieldSetDataEntryComRespDto = fwCompDataSetSingleEntryClient.implementSingleMultipleFieldSetDataEntryCom(implementSingleMultipleFieldSetDataEntryComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;


                ImplementSeparateAddOrDeleteDocListComRespDto implementSeparateAddOrDeleteDocListComRespDto_1 = null;
                if (implementSingleMultipleFieldSetDataEntryComRespDto != null && addOfficialDocumentBodyComRespDto != null) {
                    ImplementSeparateAddOrDeleteDocListComReqDto implementSeparateAddOrDeleteDocListComReqDto_1 = new ImplementSeparateAddOrDeleteDocListComReqDto();
                    implementSeparateAddOrDeleteDocListComReqDto_1.setIsCleanPersonalInvalidDocument("FALSE");//sourceId:1934775_1_69758
                    implementSeparateAddOrDeleteDocListComReqDto_1.setDocUseSceneCode("WORK_TASKS");//sourceId:1856051_1_69758
                    implementSeparateAddOrDeleteDocListComReqDto_1.setDocUseType("OFFICIAL_DOCUMENT_FILE");//sourceId:1856052_1_69758
                    implementSeparateAddOrDeleteDocListComReqDto_1.setIsResult("FALSE");//sourceId:1859365_1_69758
                    implementSeparateAddOrDeleteDocListComReqDto_1.setOwnTableTypeCode("OMS_OFFICIAL_DOCUMENT");//sourceId:1856054_1_69758
                    implementSeparateAddOrDeleteDocListComReqDto_1.setUserId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecUserId());//CURRENT_USERID//sourceId:1856060_1_69758
                    implementSeparateAddOrDeleteDocListComReqDto_1.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1856049_1_69758
                    if (implementSingleMultipleFieldSetDataEntryComRespDto != null && implementSingleMultipleFieldSetDataEntryComRespDto.getComDatasList() != null && !CollectionUtil.isEmpty(implementSingleMultipleFieldSetDataEntryComRespDto.getComDatasList())) {
                        implementSeparateAddOrDeleteDocListComReqDto_1.setDocumentList(//objList-to-objLists
                                implementSingleMultipleFieldSetDataEntryComRespDto.getComDatasList().stream().map(item -> {
                                    com.wicket.okrcomponent.integration.dto.DocumentDto elm = new com.wicket.okrcomponent.integration.dto.DocumentDto();
                                    if (item != null) {
                                        elm.setUnstructuredDataId(item.getCustomField1());//SimpleFieldAssign//sourceId:371771_2_69758
                                        elm.setPostfix(item.getCustomField2());//SimpleFieldAssign//sourceId:371775_2_69758
                                        elm.setFileRelativePathAccess(item.getCustomField3());//SimpleFieldAssign//sourceId:371776_2_69758
                                        elm.setSourceRelationshipId(item.getCustomField4());//SimpleFieldAssign//sourceId:371772_2_69758
                                        elm.setRelationshipType(item.getCustomField5());//SimpleFieldAssign//sourceId:371773_2_69758
                                        elm.setIsNetworkReference(item.getCustomField6());//SimpleFieldAssign//sourceId:371774_2_69758
                                    }
                                    return elm;
                                }).collect(Collectors.toList()));//objList-to-objLists//sourceId:1856050_1_69758
                    }
                    if (addOfficialDocumentBodyComRespDto != null) {
                        implementSeparateAddOrDeleteDocListComReqDto_1.setOwnEntityId(addOfficialDocumentBodyComRespDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1856048_1_69758
                    }

                    /*D2新增或删除公文主体文档关系(公共)[8783]   */
                    Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto_1.getIsCleanPersonalInvalidDocument(), "D3新增公文-D2新增或删除公文主体文档关系(公共)-是否清理个人无效文档不能为空", false);
                    Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto_1.getDocUseSceneCode(), "D3新增公文-D2新增或删除公文主体文档关系(公共)-文档应用业务场景不能为空", false);
                    Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto_1.getDocUseType(), "D3新增公文-D2新增或删除公文主体文档关系(公共)-文档用途类型不能为空", false);
                    Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto_1.getIsResult(), "D3新增公文-D2新增或删除公文主体文档关系(公共)-冗余是否结果文档不能为空", false);
                    Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto_1.getOwnEntityId(), "D3新增公文-D2新增或删除公文主体文档关系(公共)-归属内容表主键ID不能为空", false);
                    Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto_1.getOwnTableTypeCode(), "D3新增公文-D2新增或删除公文主体文档关系(公共)-归属内容表类型编码不能为空", false);
                    Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto_1.getUserId(), "D3新增公文-D2新增或删除公文主体文档关系(公共)-归属个人账号不能为空", false);
                    Assert.isNull(implementSeparateAddOrDeleteDocListComReqDto_1.getSpaceId(), "D3新增公文-D2新增或删除公文主体文档关系(公共)-创建于空间ID不能为空", false);
                    implementSeparateAddOrDeleteDocListComRespDto_1 = unstructuredDataService.implementSeparateAddOrDeleteDocListCom(implementSeparateAddOrDeleteDocListComReqDto_1).getData()/*vcase invoke 跨dubbo调用;*/;


                }
                UpdateOfficialDocumentBodyComRespDto updateOfficialDocumentBodyComRespDto = null;
                if (addOfficialDocumentBodyComRespDto != null && implementDataAppointFormatShiftTextComRespDto != null) {
                    UpdateOfficialDocumentBodyComReqDto updateOfficialDocumentBodyComReqDto = new UpdateOfficialDocumentBodyComReqDto();
                    if (addOfficialDocumentBodyComRespDto != null) {
                        updateOfficialDocumentBodyComReqDto.setOfficialDocumentId(addOfficialDocumentBodyComRespDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1313389_1_53618
                    }
                    if (reqDto != null) {
                        updateOfficialDocumentBodyComReqDto.setOfficialDocumentFileAddress(reqDto.getFileRelativePathAccess());//SimpleFieldAssign//sourceId:1313391_1_53618
                    }
                    if (implementDataAppointFormatShiftTextComRespDto != null) {
                        updateOfficialDocumentBodyComReqDto.setAnnexAddress(implementDataAppointFormatShiftTextComRespDto.getCustomText());//SimpleFieldAssign//sourceId:1313463_1_53618
                    }

                    /*D3写入公文文件地址[7923]   */
                    Assert.isNull(updateOfficialDocumentBodyComReqDto.getOfficialDocumentId(), "D3新增公文-D3写入公文文件地址-公文ID不能为空", false);
                    Assert.isNull(updateOfficialDocumentBodyComReqDto.getOfficialDocumentFileAddress(), "D3新增公文-D3写入公文文件地址-公文文件地址不能为空", false);
                    updateOfficialDocumentBodyComRespDto = updateOfficialDocumentBodyCom(updateOfficialDocumentBodyComReqDto)/*vcase invoke 同服务,同domain*/;


                }
            }
            if ((reqDto != null && reqDto.getIsOpenWorkTask() != null && reqDto.getIsOpenWorkTask().equals("TRUE"))) {
                //if(D3新增公文.是否开启工作任务 等于 是)  53503

                UpdateOfficialDocumentBodyComRespDto updateOfficialDocumentBodyComRespDto_1 = null;
                if (addOfficialDocumentBodyComRespDto != null) {
                    UpdateOfficialDocumentBodyComReqDto updateOfficialDocumentBodyComReqDto_1 = new UpdateOfficialDocumentBodyComReqDto();
                    updateOfficialDocumentBodyComReqDto_1.setWorkTaskIsArrange("FALSE");//sourceId:1311510_1_53504
                    if (addOfficialDocumentBodyComRespDto != null) {
                        updateOfficialDocumentBodyComReqDto_1.setOfficialDocumentId(addOfficialDocumentBodyComRespDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1311509_1_53504
                    }

                    /*D3修改公文工作任务是否已安排为否[7923]   */
                    Assert.isNull(updateOfficialDocumentBodyComReqDto_1.getOfficialDocumentId(), "D3新增公文-D3修改公文工作任务是否已安排为否-公文ID不能为空", false);
                    Assert.isNull(updateOfficialDocumentBodyComReqDto_1.getWorkTaskIsArrange(), "D3新增公文-D3修改公文工作任务是否已安排为否-工作任务是否已安排不能为空", false);
                    updateOfficialDocumentBodyComRespDto_1 = updateOfficialDocumentBodyCom(updateOfficialDocumentBodyComReqDto_1)/*vcase invoke 同服务,同domain*/;


                }
            }
            if ((reqDto != null && reqDto.getSubjectLifeCycle() != null && reqDto.getSubjectLifeCycle().equals("CURRENTLY_VALID"))) {
                //if(D3新增公文.主体生命周期 等于 当前有效)  54069

                ImplementNotificationTypeMsgTempanAlyzeComRespDto implementNotificationTypeMsgTempanAlyzeComRespDto = null;
                ImplementNotificationTypeMsgTempanAlyzeComReqDto implementNotificationTypeMsgTempanAlyzeComReqDto = new ImplementNotificationTypeMsgTempanAlyzeComReqDto();
                if (reqDto != null) {
                    implementNotificationTypeMsgTempanAlyzeComReqDto.setNotificationType(reqDto.getNotificationType());//SimpleFieldAssign//sourceId:1418200_1_56690
                    implementNotificationTypeMsgTempanAlyzeComReqDto.setReceiveRange(reqDto.getReceiveRange());//SimpleFieldAssign//sourceId:1418201_1_56690
                }

                /*D3执行通知类型消息模板分析(公共)[8153]   */
                Assert.isNull(implementNotificationTypeMsgTempanAlyzeComReqDto.getNotificationType(), "D3新增公文-D3执行通知类型消息模板分析(公共)-通知类型不能为空", false);
                Assert.isNull(implementNotificationTypeMsgTempanAlyzeComReqDto.getReceiveRange(), "D3新增公文-D3执行通知类型消息模板分析(公共)-接收范围不能为空", false);
                implementNotificationTypeMsgTempanAlyzeComRespDto = implementNotificationTypeMsgTempanAlyzeCom(implementNotificationTypeMsgTempanAlyzeComReqDto)/*vcase invoke 同服务,同domain*/;


                if ((reqDto != null && reqDto.getReceiveRange() != null && reqDto.getReceiveRange().equals("EVERYONE"))) {
                    //if(D3新增公文.接收范围 等于 所有人)  54072

                    ImplementIssueOfficialDoSendOrgMemberMsgComRespDto implementIssueOfficialDoSendOrgMemberMsgComRespDto = null;
                    if (addOfficialDocumentBodyComRespDto != null && implementNotificationTypeMsgTempanAlyzeComRespDto != null) {
                        ImplementIssueOfficialDoSendOrgMemberMsgComReqDto implementIssueOfficialDoSendOrgMemberMsgComReqDto = new ImplementIssueOfficialDoSendOrgMemberMsgComReqDto();
                        implementIssueOfficialDoSendOrgMemberMsgComReqDto.setCooperateContentTypeCode("OMS_OFFICIAL_DOCUMENT");//sourceId:1331863_1_54160
                        if (addOfficialDocumentBodyComRespDto != null) {
                            implementIssueOfficialDoSendOrgMemberMsgComReqDto.setOfficialDocumentId(addOfficialDocumentBodyComRespDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1328759_1_54160
                            implementIssueOfficialDoSendOrgMemberMsgComReqDto.setCooperateContentId(addOfficialDocumentBodyComRespDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1331864_1_54160
                        }
                        if (reqDto != null) {
                            implementIssueOfficialDoSendOrgMemberMsgComReqDto.setOfficialDocumentName(reqDto.getOfficialDocumentName());//SimpleFieldAssign//sourceId:1328760_1_54160
                            implementIssueOfficialDoSendOrgMemberMsgComReqDto.setMessageImportantLevel(reqDto.getRemindLevel());//SimpleFieldAssign//sourceId:1328798_1_54160
                            implementIssueOfficialDoSendOrgMemberMsgComReqDto.setSurfaceContName(reqDto.getOfficialDocumentName());//SimpleFieldAssign//sourceId:1331865_1_54160
                        }
                        if (implementNotificationTypeMsgTempanAlyzeComRespDto != null) {
                            implementIssueOfficialDoSendOrgMemberMsgComReqDto.setSendMsgScene(implementNotificationTypeMsgTempanAlyzeComRespDto.getSendMsgScene());//SimpleFieldAssign//sourceId:1465655_1_54160
                            implementIssueOfficialDoSendOrgMemberMsgComReqDto.setMessageTemplateCode(implementNotificationTypeMsgTempanAlyzeComRespDto.getMessageTemplateCode());//SimpleFieldAssign//sourceId:1465656_1_54160
                            implementIssueOfficialDoSendOrgMemberMsgComReqDto.setMsgTitleTemplateSemanticEngineCode(implementNotificationTypeMsgTempanAlyzeComRespDto.getMsgTitleTemplateSemanticEngineCode());//SimpleFieldAssign//sourceId:1465657_1_54160
                        }

                        /*D3执行下发公文给组织成员发消息(公共)[7968]   */
                        Assert.isNull(implementIssueOfficialDoSendOrgMemberMsgComReqDto.getOfficialDocumentId(), "D3新增公文-D3执行下发公文给组织成员发消息(公共)-公文ID不能为空", false);
                        Assert.isNull(implementIssueOfficialDoSendOrgMemberMsgComReqDto.getOfficialDocumentName(), "D3新增公文-D3执行下发公文给组织成员发消息(公共)-公文名称不能为空", false);
                        Assert.isNull(implementIssueOfficialDoSendOrgMemberMsgComReqDto.getMessageImportantLevel(), "D3新增公文-D3执行下发公文给组织成员发消息(公共)-消息重要紧急度层级不能为空", false);
                        Assert.isNull(implementIssueOfficialDoSendOrgMemberMsgComReqDto.getCooperateContentTypeCode(), "D3新增公文-D3执行下发公文给组织成员发消息(公共)-协同内容类型编码不能为空", false);
                        Assert.isNull(implementIssueOfficialDoSendOrgMemberMsgComReqDto.getCooperateContentId(), "D3新增公文-D3执行下发公文给组织成员发消息(公共)-协同内容ID不能为空", false);
                        Assert.isNull(implementIssueOfficialDoSendOrgMemberMsgComReqDto.getSurfaceContName(), "D3新增公文-D3执行下发公文给组织成员发消息(公共)-协同内容名称不能为空", false);
                        Assert.isNull(implementIssueOfficialDoSendOrgMemberMsgComReqDto.getSendMsgScene(), "D3新增公文-D3执行下发公文给组织成员发消息(公共)-发送消息场景不能为空", false);
                        Assert.isNull(implementIssueOfficialDoSendOrgMemberMsgComReqDto.getMessageTemplateCode(), "D3新增公文-D3执行下发公文给组织成员发消息(公共)-消息模板标识不能为空", false);
                        Assert.isNull(implementIssueOfficialDoSendOrgMemberMsgComReqDto.getMsgTitleTemplateSemanticEngineCode(), "D3新增公文-D3执行下发公文给组织成员发消息(公共)-消息标题模板引擎标识不能为空", false);
                        implementIssueOfficialDoSendOrgMemberMsgComRespDto = messageService.implementIssueOfficialDoSendOrgMemberMsgCom(implementIssueOfficialDoSendOrgMemberMsgComReqDto)/*vcase invoke isSameApp*/;


                    }
                } else if ((reqDto != null && reqDto.getReceiveRange() != null && reqDto.getReceiveRange().equals("DEPT") && reqDto != null && reqDto.getDeptList() != null && reqDto.getDeptList().size() > 0)) {
                    //elseif((D3新增公文.接收范围 等于 部门 and D3新增公文.部门列表数据集条数 大于 0))  54073

                    ImplementIssueOfficialDoSendDeptMemberMsgComRespDto implementIssueOfficialDoSendDeptMemberMsgComRespDto = null;
                    if (addOfficialDocumentBodyComRespDto != null && implementNotificationTypeMsgTempanAlyzeComRespDto != null) {
                        ImplementIssueOfficialDoSendDeptMemberMsgComReqDto implementIssueOfficialDoSendDeptMemberMsgComReqDto = new ImplementIssueOfficialDoSendDeptMemberMsgComReqDto();
                        implementIssueOfficialDoSendDeptMemberMsgComReqDto.setCooperateContentTypeCode("OMS_OFFICIAL_DOCUMENT");//sourceId:1331866_1_54161
                        if (reqDto != null && reqDto.getDeptList() != null && !CollectionUtil.isEmpty(reqDto.getDeptList())) {
                            implementIssueOfficialDoSendDeptMemberMsgComReqDto.setDeptList(reqDto.getDeptList().stream().map(item -> BeanUtil.toBean(item, DeptDto.class)).collect(Collectors.toList()));//objList-to-objLists//sourceId:1328756_1_54161
                        }
                        if (addOfficialDocumentBodyComRespDto != null) {
                            implementIssueOfficialDoSendDeptMemberMsgComReqDto.setOfficialDocumentId(addOfficialDocumentBodyComRespDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1328757_1_54161
                            implementIssueOfficialDoSendDeptMemberMsgComReqDto.setCooperateContentId(addOfficialDocumentBodyComRespDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1331867_1_54161
                        }
                        if (reqDto != null) {
                            implementIssueOfficialDoSendDeptMemberMsgComReqDto.setOfficialDocumentName(reqDto.getOfficialDocumentName());//SimpleFieldAssign//sourceId:1328758_1_54161
                            implementIssueOfficialDoSendDeptMemberMsgComReqDto.setSurfaceContName(reqDto.getOfficialDocumentName());//SimpleFieldAssign//sourceId:1331868_1_54161
                            implementIssueOfficialDoSendDeptMemberMsgComReqDto.setMessageImportantLevel(reqDto.getRemindLevel());//SimpleFieldAssign//sourceId:1331869_1_54161
                        }
                        if (implementNotificationTypeMsgTempanAlyzeComRespDto != null) {
                            implementIssueOfficialDoSendDeptMemberMsgComReqDto.setSendMsgScene(implementNotificationTypeMsgTempanAlyzeComRespDto.getSendMsgScene());//SimpleFieldAssign//sourceId:1465237_1_54161
                            implementIssueOfficialDoSendDeptMemberMsgComReqDto.setMessageTemplateCode(implementNotificationTypeMsgTempanAlyzeComRespDto.getMessageTemplateCode());//SimpleFieldAssign//sourceId:1465238_1_54161
                            implementIssueOfficialDoSendDeptMemberMsgComReqDto.setMsgTitleTemplateSemanticEngineCode(implementNotificationTypeMsgTempanAlyzeComRespDto.getMsgTitleTemplateSemanticEngineCode());//SimpleFieldAssign//sourceId:1465239_1_54161
                        }

                        /*D3执行下发公文给部门成员发消息(公共)[7969]   */
                        Assert.isNull(implementIssueOfficialDoSendDeptMemberMsgComReqDto.getOfficialDocumentId(), "D3新增公文-D3执行下发公文给部门成员发消息(公共)-公文ID不能为空", false);
                        Assert.isNull(implementIssueOfficialDoSendDeptMemberMsgComReqDto.getOfficialDocumentName(), "D3新增公文-D3执行下发公文给部门成员发消息(公共)-公文名称不能为空", false);
                        Assert.isNull(implementIssueOfficialDoSendDeptMemberMsgComReqDto.getCooperateContentTypeCode(), "D3新增公文-D3执行下发公文给部门成员发消息(公共)-协同内容类型编码不能为空", false);
                        Assert.isNull(implementIssueOfficialDoSendDeptMemberMsgComReqDto.getCooperateContentId(), "D3新增公文-D3执行下发公文给部门成员发消息(公共)-协同内容ID不能为空", false);
                        Assert.isNull(implementIssueOfficialDoSendDeptMemberMsgComReqDto.getSurfaceContName(), "D3新增公文-D3执行下发公文给部门成员发消息(公共)-协同内容名称不能为空", false);
                        Assert.isNull(implementIssueOfficialDoSendDeptMemberMsgComReqDto.getMessageImportantLevel(), "D3新增公文-D3执行下发公文给部门成员发消息(公共)-消息重要紧急度层级不能为空", false);
                        Assert.isNull(implementIssueOfficialDoSendDeptMemberMsgComReqDto.getSendMsgScene(), "D3新增公文-D3执行下发公文给部门成员发消息(公共)-发送消息场景不能为空", false);
                        Assert.isNull(implementIssueOfficialDoSendDeptMemberMsgComReqDto.getMessageTemplateCode(), "D3新增公文-D3执行下发公文给部门成员发消息(公共)-消息模板标识不能为空", false);
                        Assert.isNull(implementIssueOfficialDoSendDeptMemberMsgComReqDto.getMsgTitleTemplateSemanticEngineCode(), "D3新增公文-D3执行下发公文给部门成员发消息(公共)-消息标题模板引擎标识不能为空", false);
                        implementIssueOfficialDoSendDeptMemberMsgComRespDto = messageService.implementIssueOfficialDoSendDeptMemberMsgCom(implementIssueOfficialDoSendDeptMemberMsgComReqDto)/*vcase invoke isSameApp*/;


                    }
                } else if ((reqDto != null && reqDto.getReceiveRange() != null && reqDto.getReceiveRange().equals("PERSON") && reqDto != null && reqDto.getOrgInductionRecordList() != null && reqDto.getOrgInductionRecordList().size() > 0)) {
                    //elseif((D3新增公文.接收范围 等于 个人 and D3新增公文.就职记录列表数据集条数 大于 0))  54159

                    ImplementLoopSinglePersonSendMsgComRespDto implementLoopSinglePersonSendMsgComRespDto = null;
                    if (addOfficialDocumentBodyComRespDto != null && implementNotificationTypeMsgTempanAlyzeComRespDto != null) {
                        ImplementLoopSinglePersonSendMsgComReqDto implementLoopSinglePersonSendMsgComReqDto = new ImplementLoopSinglePersonSendMsgComReqDto();
                        implementLoopSinglePersonSendMsgComReqDto.setTableTypeCode("OMS_OFFICIAL_DOCUMENT");//sourceId:1381942_1_55912
                        implementLoopSinglePersonSendMsgComReqDto.setCooperateContentTypeCode("OMS_OFFICIAL_DOCUMENT");//sourceId:1381950_1_55912
                        if (reqDto != null) {
                            implementLoopSinglePersonSendMsgComReqDto.setOrgInductionRecordList(reqDto.getOrgInductionRecordList());//list-field-assign//sourceId:1381941_1_55912
                            implementLoopSinglePersonSendMsgComReqDto.setObjectName(reqDto.getOfficialDocumentName());//SimpleFieldAssign//sourceId:1381944_1_55912
                            implementLoopSinglePersonSendMsgComReqDto.setMessageImportantLevel(reqDto.getRemindLevel());//SimpleFieldAssign//sourceId:1381949_1_55912
                            implementLoopSinglePersonSendMsgComReqDto.setSurfaceContName(reqDto.getOfficialDocumentName());//SimpleFieldAssign//sourceId:1381952_1_55912
                        }
                        if (addOfficialDocumentBodyComRespDto != null) {
                            implementLoopSinglePersonSendMsgComReqDto.setEntityId(addOfficialDocumentBodyComRespDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1381943_1_55912
                            implementLoopSinglePersonSendMsgComReqDto.setCooperateContentId(addOfficialDocumentBodyComRespDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1381951_1_55912
                        }
                        if (implementNotificationTypeMsgTempanAlyzeComRespDto != null) {
                            implementLoopSinglePersonSendMsgComReqDto.setSendMsgScene(implementNotificationTypeMsgTempanAlyzeComRespDto.getSendMsgScene());//SimpleFieldAssign//sourceId:1477088_1_55912
                            implementLoopSinglePersonSendMsgComReqDto.setMessageTemplateCode(implementNotificationTypeMsgTempanAlyzeComRespDto.getMessageTemplateCode());//SimpleFieldAssign//sourceId:1477086_1_55912
                            implementLoopSinglePersonSendMsgComReqDto.setMsgTitleTemplateSemanticEngineCode(implementNotificationTypeMsgTempanAlyzeComRespDto.getMsgTitleTemplateSemanticEngineCode());//SimpleFieldAssign//sourceId:1477094_1_55912
                        }

                        /*D3执行循环单人发消息(公共)[8086]   */
                        Assert.isNull(implementLoopSinglePersonSendMsgComReqDto.getTableTypeCode(), "D3新增公文-D3执行循环单人发消息(公共)-内容表类型编码不能为空", false);
                        Assert.isNull(implementLoopSinglePersonSendMsgComReqDto.getEntityId(), "D3新增公文-D3执行循环单人发消息(公共)-内容表主键ID不能为空", false);
                        Assert.isNull(implementLoopSinglePersonSendMsgComReqDto.getObjectName(), "D3新增公文-D3执行循环单人发消息(公共)-对象名称不能为空", false);
                        Assert.isNull(implementLoopSinglePersonSendMsgComReqDto.getMessageImportantLevel(), "D3新增公文-D3执行循环单人发消息(公共)-消息重要紧急度层级不能为空", false);
                        Assert.isNull(implementLoopSinglePersonSendMsgComReqDto.getCooperateContentTypeCode(), "D3新增公文-D3执行循环单人发消息(公共)-协同内容类型编码不能为空", false);
                        Assert.isNull(implementLoopSinglePersonSendMsgComReqDto.getCooperateContentId(), "D3新增公文-D3执行循环单人发消息(公共)-协同内容ID不能为空", false);
                        Assert.isNull(implementLoopSinglePersonSendMsgComReqDto.getSurfaceContName(), "D3新增公文-D3执行循环单人发消息(公共)-协同内容名称不能为空", false);
                        Assert.isNull(implementLoopSinglePersonSendMsgComReqDto.getSendMsgScene(), "D3新增公文-D3执行循环单人发消息(公共)-发送消息场景不能为空", false);
                        Assert.isNull(implementLoopSinglePersonSendMsgComReqDto.getMessageTemplateCode(), "D3新增公文-D3执行循环单人发消息(公共)-消息模板标识不能为空", false);
                        Assert.isNull(implementLoopSinglePersonSendMsgComReqDto.getMsgTitleTemplateSemanticEngineCode(), "D3新增公文-D3执行循环单人发消息(公共)-消息标题模板引擎标识不能为空", false);
                        implementLoopSinglePersonSendMsgComRespDto = messageService.implementLoopSinglePersonSendMsgCom(implementLoopSinglePersonSendMsgComReqDto)/*vcase invoke isSameApp*/;


                    }
                }
                if ((reqDto != null && reqDto.getAppointWorkTaskArrangeInductionId() != null && reqDto != null && reqDto.getIsOpenWorkTask() != null && reqDto.getIsOpenWorkTask().equals("TRUE"))) {
                    //if((D3新增公文.指定工作任务安排人就职记录ID 值不等于空  and D3新增公文.是否开启工作任务 等于 是))  54165

                    QueryInductionDeptDetailComRespDto queryInductionDeptDetailComRespDto = null;
                    QueryInductionDeptDetailComReqDto queryInductionDeptDetailComReqDto = new QueryInductionDeptDetailComReqDto();
                    queryInductionDeptDetailComReqDto.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1477125_1_59123
                    if (reqDto != null) {
                        queryInductionDeptDetailComReqDto.setInductionRecordId(reqDto.getAppointWorkTaskArrangeInductionId());//SimpleFieldAssign//sourceId:1477124_1_59123
                    }

                    /*D1查工作任务安排人身份人员ID[7829]   */
                    Assert.isNull(queryInductionDeptDetailComReqDto.getInductionRecordId(), "D3新增公文-D1查工作任务安排人身份人员ID-就职记录ID不能为空", false);
                    Assert.isNull(queryInductionDeptDetailComReqDto.getSpaceId(), "D3新增公文-D1查工作任务安排人身份人员ID-创建于空间ID不能为空", false);
                    queryInductionDeptDetailComRespDto = inductionRecordService.queryInductionDeptDetailCom(queryInductionDeptDetailComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;


                    ImplementSendTwoPersonConvMsgAndNumComRespDto implementSendTwoPersonConvMsgAndNumComRespDto = null;
                    if (queryInductionDeptDetailComRespDto != null && addOfficialDocumentBodyComRespDto != null) {
                        ImplementSendTwoPersonConvMsgAndNumComReqDto implementSendTwoPersonConvMsgAndNumComReqDto = new ImplementSendTwoPersonConvMsgAndNumComReqDto();
                        implementSendTwoPersonConvMsgAndNumComReqDto.setSendMsgScene("ISSUE_OFFICIAL_DOC_WORK_TASK_ARRANGE");//sourceId:1477097_1_59122
                        implementSendTwoPersonConvMsgAndNumComReqDto.setSurfaceCode("OMS_OFFICIAL_DOCUMENT");//sourceId:1477144_1_59122
                        implementSendTwoPersonConvMsgAndNumComReqDto.setTableTypeCode("OMS_OFFICIAL_DOCUMENT");//sourceId:1477107_1_59122
                        implementSendTwoPersonConvMsgAndNumComReqDto.setCooperateContentTypeCode("OMS_OFFICIAL_DOCUMENT");//sourceId:1477109_1_59122
                        implementSendTwoPersonConvMsgAndNumComReqDto.setIsHandle("FALSE");//sourceId:1477117_1_59122
                        implementSendTwoPersonConvMsgAndNumComReqDto.setHandleType("NEED_BUSINESS_OPERATION_HANDLING");//sourceId:1477118_1_59122
                        implementSendTwoPersonConvMsgAndNumComReqDto.setPlatformReplace("FALSE");//sourceId:1477121_1_59122
                        implementSendTwoPersonConvMsgAndNumComReqDto.setMessageImportantLevel(Long.valueOf(4));//CUSTOM_CONVENTION//sourceId:1477113_1_59122
                        implementSendTwoPersonConvMsgAndNumComReqDto.setMessageTemplateCode("ARRANGE_WORK_TASK_INSTRUCT_TEMP");//CUSTOM_CONVENTION//sourceId:1477106_1_59122
                        implementSendTwoPersonConvMsgAndNumComReqDto.setFirstFieldName("objectName");//CUSTOM_CONVENTION//sourceId:1477102_1_59122
                        implementSendTwoPersonConvMsgAndNumComReqDto.setMsgTitleTemplateSemanticEngineCode("ISSUE_OFFICIAL_DOC_WORK_TASK_ARRANGE_MSG_TITLE");//CUSTOM_CONVENTION//sourceId:1477101_1_59122
                        implementSendTwoPersonConvMsgAndNumComReqDto.setComNumField(Long.valueOf(2));//CUSTOM_CONVENTION//sourceId:1477114_1_59122
                        implementSendTwoPersonConvMsgAndNumComReqDto.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1477099_1_59122
                        implementSendTwoPersonConvMsgAndNumComReqDto.setAppId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecAppId());//CURRENT_APPID//sourceId:1477100_1_59122
                        if (queryInductionDeptDetailComRespDto != null) {
                            implementSendTwoPersonConvMsgAndNumComReqDto.setReceiveOriginalRoleMemberId(queryInductionDeptDetailComRespDto.getOriginalRoleMemberId());//SimpleFieldAssign//sourceId:1477096_1_59122
                        }
                        if (addOfficialDocumentBodyComRespDto != null) {
                            implementSendTwoPersonConvMsgAndNumComReqDto.setEntityId(addOfficialDocumentBodyComRespDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1477145_1_59122
                            implementSendTwoPersonConvMsgAndNumComReqDto.setTableContentEntityId(addOfficialDocumentBodyComRespDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1547109_1_59122
                            implementSendTwoPersonConvMsgAndNumComReqDto.setCooperateContentId(addOfficialDocumentBodyComRespDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1477110_1_59122
                        }
                        if (reqDto != null) {
                            implementSendTwoPersonConvMsgAndNumComReqDto.setSurfaceContName(reqDto.getOfficialDocumentName());//SimpleFieldAssign//sourceId:1477111_1_59122
                            implementSendTwoPersonConvMsgAndNumComReqDto.setFirstFieldValue(reqDto.getOfficialDocumentName());//SimpleFieldAssign//sourceId:1477103_1_59122
                        }

                        /*D3执行发两人会话消息及数量(公共)[8262]   */
                        Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getSendMsgScene(), "D3新增公文-D3执行发两人会话消息及数量(公共)-发送消息场景不能为空", false);
                        Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getReceiveOriginalRoleMemberId(), "D3新增公文-D3执行发两人会话消息及数量(公共)-接收方身份人员ID不能为空", false);
                        Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getSurfaceCode(), "D3新增公文-D3执行发两人会话消息及数量(公共)-归属内容类型编码不能为空", false);
                        Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getEntityId(), "D3新增公文-D3执行发两人会话消息及数量(公共)-归属内容ID不能为空", false);
                        Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getTableTypeCode(), "D3新增公文-D3执行发两人会话消息及数量(公共)-冗余内容表类型编码不能为空", false);
                        Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getTableContentEntityId(), "D3新增公文-D3执行发两人会话消息及数量(公共)-冗余内容表主键ID不能为空", false);
                        Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getCooperateContentTypeCode(), "D3新增公文-D3执行发两人会话消息及数量(公共)-协同内容类型编码不能为空", false);
                        Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getCooperateContentId(), "D3新增公文-D3执行发两人会话消息及数量(公共)-协同内容ID不能为空", false);
                        Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getSurfaceContName(), "D3新增公文-D3执行发两人会话消息及数量(公共)-协同内容名称不能为空", false);
                        Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getIsHandle(), "D3新增公文-D3执行发两人会话消息及数量(公共)-是否已处理不能为空", false);
                        Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getHandleType(), "D3新增公文-D3执行发两人会话消息及数量(公共)-处理类型不能为空", false);
                        Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getPlatformReplace(), "D3新增公文-D3执行发两人会话消息及数量(公共)-是否平台代操作不能为空", false);
                        Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getMessageImportantLevel(), "D3新增公文-D3执行发两人会话消息及数量(公共)-消息重要紧急度层级不能为空", false);
                        Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getMessageTemplateCode(), "D3新增公文-D3执行发两人会话消息及数量(公共)-消息模板标识不能为空", false);
                        Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getFirstFieldName(), "D3新增公文-D3执行发两人会话消息及数量(公共)-第一个字段字段名不能为空", false);
                        Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getFirstFieldValue(), "D3新增公文-D3执行发两人会话消息及数量(公共)-第一个字段字段值不能为空", false);
                        Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getMsgTitleTemplateSemanticEngineCode(), "D3新增公文-D3执行发两人会话消息及数量(公共)-消息标题模板引擎标识不能为空", false);
                        Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getComNumField(), "D3新增公文-D3执行发两人会话消息及数量(公共)-通用数值字段（整数型）不能为空", false);
                        Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getSpaceId(), "D3新增公文-D3执行发两人会话消息及数量(公共)-创建于空间ID不能为空", false);
                        Assert.isNull(implementSendTwoPersonConvMsgAndNumComReqDto.getAppId(), "D3新增公文-D3执行发两人会话消息及数量(公共)-创建于联盟应用ID不能为空", false);
                        implementSendTwoPersonConvMsgAndNumComRespDto = messageService.implementSendTwoPersonConvMsgAndNumCom(implementSendTwoPersonConvMsgAndNumComReqDto)/*vcase invoke isSameApp*/;


                    }
                }
            }
        } else {
            //else  53520

//异常结束 53521
            throw new BizException("500", "系统异常，请联系管理员！", false);
        }
//virtualUsage D2查平台文件存储根路径配置答案（公共）  71630
        QueryConfItemMatchAnswerDetailComRespDto queryConfItemMatchAnswerDetailComRespDto = null;
        QueryConfItemMatchAnswerDetailComReqDto queryConfItemMatchAnswerDetailComReqDto = new QueryConfItemMatchAnswerDetailComReqDto();
        queryConfItemMatchAnswerDetailComReqDto.setConfItemCode("FILE_STORAGE_ROOT_PATH");//CUSTOM_CONVENTION//sourceId:1935149_1_71630
        queryConfItemMatchAnswerDetailComReqDto.setConfSchemeCode("COM_CONF_SCHEME");//CUSTOM_CONVENTION//sourceId:1935150_1_71630
        queryConfItemMatchAnswerDetailComReqDto.setIsPlatData("TRUE");//sourceId:1935151_1_71630

        /*D2查平台文件存储根路径配置答案（公共）[2486]   */
        Assert.isNull(queryConfItemMatchAnswerDetailComReqDto.getConfItemCode(), "D3新增公文-D2查平台文件存储根路径配置答案（公共）-配置项标识不能为空", false);
        Assert.isNull(queryConfItemMatchAnswerDetailComReqDto.getConfSchemeCode(), "D3新增公文-D2查平台文件存储根路径配置答案（公共）-配置方案标识不能为空", false);
        Assert.isNull(queryConfItemMatchAnswerDetailComReqDto.getIsPlatData(), "D3新增公文-D2查平台文件存储根路径配置答案（公共）-是否标准答案不能为空", false);
        queryConfItemMatchAnswerDetailComRespDto = confSchemeService.queryConfItemMatchAnswerDetailCom(queryConfItemMatchAnswerDetailComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;


//virtualUsage D2执行清理个人用户无效文件(公共)  71631
        ImplementClearMemberInvalidDocComRespDto implementClearMemberInvalidDocComRespDto = null;
        if (queryConfItemMatchAnswerDetailComRespDto != null) {
            ImplementClearMemberInvalidDocComReqDto implementClearMemberInvalidDocComReqDto = new ImplementClearMemberInvalidDocComReqDto();
            implementClearMemberInvalidDocComReqDto.setIsCleanPersonalInvalidDocument("TRUE");//sourceId:1935156_1_71631
            implementClearMemberInvalidDocComReqDto.setUserId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecUserId());//CURRENT_USERID//sourceId:1935154_1_71631
            if (queryConfItemMatchAnswerDetailComRespDto != null) {
                implementClearMemberInvalidDocComReqDto.setFileStorageRootPath(queryConfItemMatchAnswerDetailComRespDto.getEndValue());//SimpleFieldAssign//sourceId:1935155_1_71631
            }

            /*D2执行清理个人用户无效文件(公共)[8792]   */
            Assert.isNull(implementClearMemberInvalidDocComReqDto.getIsCleanPersonalInvalidDocument(), "D3新增公文-D2执行清理个人用户无效文件(公共)-是否清理个人无效文档不能为空", false);
            Assert.isNull(implementClearMemberInvalidDocComReqDto.getUserId(), "D3新增公文-D2执行清理个人用户无效文件(公共)-归属个人账号不能为空", false);
            Assert.isNull(implementClearMemberInvalidDocComReqDto.getFileStorageRootPath(), "D3新增公文-D2执行清理个人用户无效文件(公共)-文件存储根路径不能为空", false);
            implementClearMemberInvalidDocComRespDto = unstructuredDataService.implementClearMemberInvalidDocCom(implementClearMemberInvalidDocComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;


        }
        AddOfficialDocumentRespDto retData = new AddOfficialDocumentRespDto();
        if (addOfficialDocumentBodyComRespDto_1 != null) {
            retData.setOfficialDocumentId(addOfficialDocumentBodyComRespDto_1.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1311571_1
        }


        return retData;
    }

    /**
     * D3-9修改公文主体(公共)[7923]
     * gen by moon at 12/6/2023, 6:25:45 AM
     */
    @Trace(operationName = "D3-9修改公文主体(公共)")
    @Tags({@Tag(key = "参数", value = "arg[0]"),
            @Tag(key = "返回值", value = "returnedObj")})
    @Transactional(rollbackFor = Exception.class)
    @Override
    public UpdateOfficialDocumentBodyComRespDto updateOfficialDocumentBodyCom(UpdateOfficialDocumentBodyComReqDto reqDto) {


        //步骤0: 3-9-01修改公文 - updateOfficialDocument
        boolean bOOLEAN;
        OmsOfficialDocument omsOfficialDocument = new OmsOfficialDocument();
        if (reqDto != null) {
            omsOfficialDocument.setOfficialDocumentId(reqDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1311478_1
            omsOfficialDocument.setOfficialDocumentName(reqDto.getOfficialDocumentName());//SimpleFieldAssign//sourceId:1311479_1
            omsOfficialDocument.setOfficialDocumentFileAddress(reqDto.getOfficialDocumentFileAddress());//SimpleFieldAssign//sourceId:1311480_1
            omsOfficialDocument.setAnnexAddress(reqDto.getAnnexAddress());//SimpleFieldAssign//sourceId:1311481_1
            omsOfficialDocument.setReceiveRange(reqDto.getReceiveRange());//SimpleFieldAssign//sourceId:1385415_1
            omsOfficialDocument.setRemindLevel(reqDto.getRemindLevel());//SimpleFieldAssign//sourceId:1311482_1
            omsOfficialDocument.setIsOpenWorkTask(reqDto.getIsOpenWorkTask());//SimpleFieldAssign//sourceId:1311483_1
            omsOfficialDocument.setWorkTaskIsArrange(reqDto.getWorkTaskIsArrange());//SimpleFieldAssign//sourceId:1311484_1
            omsOfficialDocument.setAppointWorkTaskArrangeInductionId(reqDto.getAppointWorkTaskArrangeInductionId());//SimpleFieldAssign//sourceId:1311485_1
            omsOfficialDocument.setArrangeWorkTaskTypeCode(reqDto.getArrangeWorkTaskTypeCode());//SimpleFieldAssign//sourceId:1346304_1
            omsOfficialDocument.setArrangeWorkTaskId(reqDto.getArrangeWorkTaskId());//SimpleFieldAssign//sourceId:1346305_1
            omsOfficialDocument.setSubjectLifeCycle(reqDto.getSubjectLifeCycle());//SimpleFieldAssign//sourceId:1311486_1
        }

        /*3-9-01修改公文[7922]   */
        Assert.isNull(omsOfficialDocument.getOfficialDocumentId(), "D3-9修改公文主体(公共)-3-9-01修改公文-公文ID不能为空", false);
        bOOLEAN = mOmsOfficialDocumentService.updateOfficialDocument(omsOfficialDocument)/*vcase invoke 本地 method 方法调用;*/;


        UpdateOfficialDocumentBodyComRespDto retData = new UpdateOfficialDocumentBodyComRespDto();


        return retData;
    }

    /**
     * D3查询公文列表[7934]
     * gen by moon at 12/17/2023, 12:26:11 PM
     */
    @Trace(operationName = "D3查询公文列表")
    @Tags({@Tag(key = "参数", value = "arg[0]"),
            @Tag(key = "返回值", value = "returnedObj")})
    @Transactional(rollbackFor = Exception.class)
    @Override
    public QueryOfficialDocumentListRespDto queryOfficialDocumentList(QueryOfficialDocumentListReqDto reqDto) {


        List<OmsOfficialDocument> listOmsOfficialDocument_1 = new ArrayList<>();
        BatchQueryInductionRecordListComRespDto batchQueryInductionRecordListComRespDto_1 = null;
//步骤0: 3-9-01执行模糊查公文列表 - implementVagueQueryOfficialDocument
        List<OmsOfficialDocument> listOmsOfficialDocument = new ArrayList<>();
        ImplementVagueQueryOfficialDocumentReq implementVagueQueryOfficialDocumentReq = new ImplementVagueQueryOfficialDocumentReq();
        implementVagueQueryOfficialDocumentReq.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1312389_1
        if (reqDto != null) {
            implementVagueQueryOfficialDocumentReq.setOfficialDocumentName(reqDto.getOfficialDocumentName());//SimpleFieldAssign//sourceId:1312382_1
            implementVagueQueryOfficialDocumentReq.setOfficialDocumentNum(reqDto.getOfficialDocumentNum());//SimpleFieldAssign//sourceId:1312383_1
            implementVagueQueryOfficialDocumentReq.setReceiveRange(reqDto.getReceiveRange());//SimpleFieldAssign//sourceId:1312384_1
            implementVagueQueryOfficialDocumentReq.setNotificationType(reqDto.getNotificationType());//SimpleFieldAssign//sourceId:1418248_1
            implementVagueQueryOfficialDocumentReq.setIsOpenWorkTask(reqDto.getIsOpenWorkTask());//SimpleFieldAssign//sourceId:1312385_1
            implementVagueQueryOfficialDocumentReq.setWorkTaskIsArrange(reqDto.getWorkTaskIsArrange());//SimpleFieldAssign//sourceId:1312386_1
            implementVagueQueryOfficialDocumentReq.setIsArchive(reqDto.getIsArchive());//SimpleFieldAssign//sourceId:1381573_1
            implementVagueQueryOfficialDocumentReq.setIssueSubjectId(reqDto.getIssueSubjectId());//SimpleFieldAssign//sourceId:1420020_1
            implementVagueQueryOfficialDocumentReq.setSubjectLifeCycle(reqDto.getSubjectLifeCycle());//SimpleFieldAssign//sourceId:1312387_1
            implementVagueQueryOfficialDocumentReq.setCreateTime(reqDto.getCreateTime());//SimpleFieldAssign//sourceId:1312388_1
        }

        /*3-9-01执行模糊查公文列表[7935]   */
        Assert.isNull(implementVagueQueryOfficialDocumentReq.getSpaceId(), "D3查询公文列表-3-9-01执行模糊查公文列表-创建于空间ID不能为空", false);
        listOmsOfficialDocument = mOmsOfficialDocumentService.implementVagueQueryOfficialDocument(implementVagueQueryOfficialDocumentReq)/*vcase invoke 本地 method 方法调用;*/;


        listOmsOfficialDocument_1 = listOmsOfficialDocument;

//步骤1: D1-3批量查询就职记录列表（公共） - batchQueryInductionRecordListCom
        BatchQueryInductionRecordListComRespDto batchQueryInductionRecordListComRespDto = null;
        if (listOmsOfficialDocument != null && !CollectionUtil.isEmpty(listOmsOfficialDocument) && listOmsOfficialDocument.size() > 0) {
            BatchQueryInductionRecordListComReqDto batchQueryInductionRecordListComReqDto = new BatchQueryInductionRecordListComReqDto();
            if (listOmsOfficialDocument != null && !CollectionUtil.isEmpty(listOmsOfficialDocument) && listOmsOfficialDocument != null && !CollectionUtil.isEmpty(listOmsOfficialDocument)) {
                batchQueryInductionRecordListComReqDto.setPerOrgInductionRecordList(listOmsOfficialDocument.stream().map(item -> item.getCreateInductionId())
                        .collect(Collectors.toList()));/*list-to-strings*///sourceId:1312426_1
            }

            /*D1-3批量查询就职记录列表（公共）[602]   */

            batchQueryInductionRecordListComRespDto = inductionRecordService.batchQueryInductionRecordListCom(batchQueryInductionRecordListComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;


            batchQueryInductionRecordListComRespDto_1 = batchQueryInductionRecordListComRespDto;
        }

        QueryOfficialDocumentListRespDto retData = new QueryOfficialDocumentListRespDto();
        //数据集融合  MoreListToOneSource
        if (listOmsOfficialDocument_1 != null && !CollectionUtil.isEmpty(listOmsOfficialDocument_1) && !CollectionUtil.isEmpty(listOmsOfficialDocument_1)) {
            for (OmsOfficialDocument omsOfficialDocument : listOmsOfficialDocument_1) {
                OfficialDocumentDto retElm = new OfficialDocumentDto();
                retElm.setOfficialDocumentId(omsOfficialDocument.getOfficialDocumentId());//SimpleFieldAssign//sourceId:267749_2
                retElm.setOfficialDocumentName(omsOfficialDocument.getOfficialDocumentName());//SimpleFieldAssign//sourceId:267750_2
                retElm.setOfficialDocumentNum(omsOfficialDocument.getOfficialDocumentNum());//SimpleFieldAssign//sourceId:267751_2
                retElm.setReceiveRange(omsOfficialDocument.getReceiveRange());//SimpleFieldAssign//sourceId:267752_2
                retElm.setWorkTaskIsArrange(omsOfficialDocument.getWorkTaskIsArrange());//SimpleFieldAssign//sourceId:284915_2
                retElm.setCreateInductionId(omsOfficialDocument.getCreateInductionId());//SimpleFieldAssign//sourceId:267821_2
                retElm.setSubjectLifeCycle(omsOfficialDocument.getSubjectLifeCycle());//SimpleFieldAssign//sourceId:267753_2
                retElm.setCreateTime(omsOfficialDocument.getCreateTime());//SimpleFieldAssign//sourceId:267754_2
                retData.getOfficialDocumentList().add(retElm);
                if (batchQueryInductionRecordListComRespDto_1 != null) {
                    for (PerOrgInductionRecordDto perOrgInductionRecordDto : batchQueryInductionRecordListComRespDto_1.getPerOrgInductionRecordList()) {
                        if (perOrgInductionRecordDto.getInductionRecordId().equals(omsOfficialDocument.getCreateInductionId())) {
                            if (batchQueryInductionRecordListComRespDto_1 != null) {
                                retElm.setUserId(perOrgInductionRecordDto.getUserId());//SimpleFieldAssign//sourceId:267817_2
                                retElm.setIdCardName(perOrgInductionRecordDto.getIdCardName());//SimpleFieldAssign//sourceId:267818_2
                                retElm.setNickName(perOrgInductionRecordDto.getNickName());//SimpleFieldAssign//sourceId:267819_2
                                retElm.setUserFace(perOrgInductionRecordDto.getUserFace());//SimpleFieldAssign//sourceId:267820_2
                            }
                        }
                    }
                }

            }
        }//sourceId:1312398_1


        return retData;
    }

    /**
     * D3删除公文[7941]
     * gen by moon at 6/9/2024, 1:09:23 AM
     */
    @Trace(operationName = "D3删除公文")
    @Tags({@Tag(key = "参数", value = "arg[0]"),
            @Tag(key = "返回值", value = "returnedObj")})
    @Transactional(rollbackFor = Exception.class)
    @Override
    public DeleteOfficialDocumentRespDto deleteOfficialDocument(DeleteOfficialDocumentReqDto reqDto) {


        //virtualUsage D3-9查询公文详情(公共)  53574
        QueryOfficialDocumentDetailComRespDto queryOfficialDocumentDetailComRespDto = null;
        QueryOfficialDocumentDetailComReqDto queryOfficialDocumentDetailComReqDto = new QueryOfficialDocumentDetailComReqDto();
        queryOfficialDocumentDetailComReqDto.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1312486_1_53574
        if (reqDto != null) {
            queryOfficialDocumentDetailComReqDto.setOfficialDocumentId(reqDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1312485_1_53574
        }

        /*D3-9查询公文详情(公共)[7930]   */
        Assert.isNull(queryOfficialDocumentDetailComReqDto.getOfficialDocumentId(), "D3删除公文-D3-9查询公文详情(公共)-公文ID不能为空", false);
        Assert.isNull(queryOfficialDocumentDetailComReqDto.getSpaceId(), "D3删除公文-D3-9查询公文详情(公共)-创建于空间ID不能为空", false);
        queryOfficialDocumentDetailComRespDto = queryOfficialDocumentDetailCom(queryOfficialDocumentDetailComReqDto)/*vcase invoke 同服务,同domain*/;


//virtualUsage D1执行生命周期判断(公共)  53575
        ImplementLifeCycleJudgmentComRespDto implementLifeCycleJudgmentComRespDto = null;
        if (queryOfficialDocumentDetailComRespDto != null) {
            ImplementLifeCycleJudgmentComReqDto implementLifeCycleJudgmentComReqDto = new ImplementLifeCycleJudgmentComReqDto();
            implementLifeCycleJudgmentComReqDto.setLifecyCycleOperationType("DELETE");//sourceId:1312490_1_53575
            if (queryOfficialDocumentDetailComRespDto != null) {
                implementLifeCycleJudgmentComReqDto.setSubjectLifeCycle(queryOfficialDocumentDetailComRespDto.getSubjectLifeCycle());//SimpleFieldAssign//sourceId:1312491_1_53575
            }

            /*D1执行生命周期判断(公共)[7830]   */
            Assert.isNull(implementLifeCycleJudgmentComReqDto.getSubjectLifeCycle(), "D3删除公文-D1执行生命周期判断(公共)-主体生命周期不能为空", false);
            Assert.isNull(implementLifeCycleJudgmentComReqDto.getLifecyCycleOperationType(), "D3删除公文-D1执行生命周期判断(公共)-生命周期操作类型不能为空", false);
            implementLifeCycleJudgmentComRespDto = batchService.implementLifeCycleJudgmentCom(implementLifeCycleJudgmentComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;


        }
//virtualUsage D3-9删除公文(公共)  53576
        DeleteOfficialDocumentComRespDto deleteOfficialDocumentComRespDto = null;
        DeleteOfficialDocumentComReqDto deleteOfficialDocumentComReqDto = new DeleteOfficialDocumentComReqDto();
        if (reqDto != null) {
            deleteOfficialDocumentComReqDto.setOfficialDocumentId(reqDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1312454_1_53576
        }

        /*D3-9删除公文(公共)[7939]   */
        Assert.isNull(deleteOfficialDocumentComReqDto.getOfficialDocumentId(), "D3删除公文-D3-9删除公文(公共)-公文ID不能为空", false);
        deleteOfficialDocumentComRespDto = deleteOfficialDocumentCom(deleteOfficialDocumentComReqDto)/*vcase invoke 同服务,同domain*/;


        if ((queryOfficialDocumentDetailComRespDto != null && queryOfficialDocumentDetailComRespDto.getOfficialDocumentFileAddress() != null)) {
            //if(D3-9查询公文详情(公共).公文文件地址 值不等于空 )  53577

            BatchDeleteDocRelOrDocComRespDto batchDeleteDocRelOrDocComRespDto = null;
            BatchDeleteDocRelOrDocComReqDto batchDeleteDocRelOrDocComReqDto = new BatchDeleteDocRelOrDocComReqDto();
            batchDeleteDocRelOrDocComReqDto.setDocUseSceneCode("WORK_TASKS");//sourceId:1857757_1_69802
            batchDeleteDocRelOrDocComReqDto.setDocUseType("OFFICIAL_DOCUMENT_FILE");//sourceId:1857758_1_69802
            batchDeleteDocRelOrDocComReqDto.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1857764_1_69802
            if (reqDto != null) {
                batchDeleteDocRelOrDocComReqDto.setOwnEntityId(reqDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1857761_1_69802
            }

            /*D2批量删公文文档关系或文档(公共)[9755]   */
            Assert.isNull(batchDeleteDocRelOrDocComReqDto.getDocUseSceneCode(), "D3删除公文-D2批量删公文文档关系或文档(公共)-文档应用业务场景不能为空", false);
            Assert.isNull(batchDeleteDocRelOrDocComReqDto.getDocUseType(), "D3删除公文-D2批量删公文文档关系或文档(公共)-文档用途类型不能为空", false);
            Assert.isNull(batchDeleteDocRelOrDocComReqDto.getOwnEntityId(), "D3删除公文-D2批量删公文文档关系或文档(公共)-归属内容表主键ID不能为空", false);
            Assert.isNull(batchDeleteDocRelOrDocComReqDto.getSpaceId(), "D3删除公文-D2批量删公文文档关系或文档(公共)-创建于空间ID不能为空", false);
            batchDeleteDocRelOrDocComRespDto = unstructuredDataService.batchDeleteDocRelOrDocCom(batchDeleteDocRelOrDocComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;


        }
        if ((queryOfficialDocumentDetailComRespDto != null && queryOfficialDocumentDetailComRespDto.getAnnexAddress() != null)) {
            //if(D3-9查询公文详情(公共).附件地址 值不等于空 )  69804

            BatchDeleteDocRelOrDocComRespDto batchDeleteDocRelOrDocComRespDto_1 = null;
            BatchDeleteDocRelOrDocComReqDto batchDeleteDocRelOrDocComReqDto_1 = new BatchDeleteDocRelOrDocComReqDto();
            batchDeleteDocRelOrDocComReqDto_1.setDocUseSceneCode("WORK_TASKS");//sourceId:1857765_1_69805
            batchDeleteDocRelOrDocComReqDto_1.setDocUseType("OFFICIAL_DOCUMENT_ANNEX");//sourceId:1857766_1_69805
            batchDeleteDocRelOrDocComReqDto_1.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1857772_1_69805
            if (reqDto != null) {
                batchDeleteDocRelOrDocComReqDto_1.setOwnEntityId(reqDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1857769_1_69805
            }

            /*D2批量删公文附件文档关系或文档(公共)[9755]   */
            Assert.isNull(batchDeleteDocRelOrDocComReqDto_1.getDocUseSceneCode(), "D3删除公文-D2批量删公文附件文档关系或文档(公共)-文档应用业务场景不能为空", false);
            Assert.isNull(batchDeleteDocRelOrDocComReqDto_1.getDocUseType(), "D3删除公文-D2批量删公文附件文档关系或文档(公共)-文档用途类型不能为空", false);
            Assert.isNull(batchDeleteDocRelOrDocComReqDto_1.getOwnEntityId(), "D3删除公文-D2批量删公文附件文档关系或文档(公共)-归属内容表主键ID不能为空", false);
            Assert.isNull(batchDeleteDocRelOrDocComReqDto_1.getSpaceId(), "D3删除公文-D2批量删公文附件文档关系或文档(公共)-创建于空间ID不能为空", false);
            batchDeleteDocRelOrDocComRespDto_1 = unstructuredDataService.batchDeleteDocRelOrDocCom(batchDeleteDocRelOrDocComReqDto_1).getData()/*vcase invoke 跨dubbo调用;*/;


        }
        DeleteOfficialDocumentRespDto retData = new DeleteOfficialDocumentRespDto();


        return retData;
    }

    /**
     * D3查我接收的公文列表[7943]
     * gen by moon at 11/12/2023, 10:34:17 PM
     */
    @Trace(operationName = "D3查我接收的公文列表")
    @Tags({@Tag(key = "参数", value = "arg[0]"),
            @Tag(key = "返回值", value = "returnedObj")})
    @Transactional(rollbackFor = Exception.class)
    @Override
    public QueryMyReceiveOfficialDocumentListRespDto queryMyReceiveOfficialDocumentList(QueryMyReceiveOfficialDocumentListReqDto reqDto) {


        List<OmsOfficialDocument> listOmsOfficialDocument_1 = new ArrayList<>();
//步骤0: D2查公文消息列表(公共) - queryOfficialDocumentMsgListCom
        QueryOfficialDocumentMsgListComRespDto queryOfficialDocumentMsgListComRespDto = null;
        QueryOfficialDocumentMsgListComReqDto queryOfficialDocumentMsgListComReqDto = new QueryOfficialDocumentMsgListComReqDto();


        /*D2查公文消息列表(公共)[7944]   */

        queryOfficialDocumentMsgListComRespDto = fwCompMessageClient.queryOfficialDocumentMsgListCom(queryOfficialDocumentMsgListComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;


//步骤1: 3-9-01批量查询模糊查公文 - batchQueryVagueQueryOfficialDocument
        List<OmsOfficialDocument> listOmsOfficialDocument = new ArrayList<>();
        if (queryOfficialDocumentMsgListComRespDto != null) {
            BatchQueryVagueQueryOfficialDocumentReq batchQueryVagueQueryOfficialDocumentReq = new BatchQueryVagueQueryOfficialDocumentReq();
            batchQueryVagueQueryOfficialDocumentReq.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1312791_1
            if (queryOfficialDocumentMsgListComRespDto != null && queryOfficialDocumentMsgListComRespDto.getOfficialDocumentMsgList() != null && !CollectionUtil.isEmpty(queryOfficialDocumentMsgListComRespDto.getOfficialDocumentMsgList())) {
                batchQueryVagueQueryOfficialDocumentReq.setOfficialDocumentList(queryOfficialDocumentMsgListComRespDto.getOfficialDocumentMsgList().stream().map(item -> item.getEntityId())
                        .collect(Collectors.toList()));/*list-to-strings*///sourceId:1312784_1
            }
            if (reqDto != null) {
                batchQueryVagueQueryOfficialDocumentReq.setOfficialDocumentName(reqDto.getOfficialDocumentName());//SimpleFieldAssign//sourceId:1312785_1
                batchQueryVagueQueryOfficialDocumentReq.setOfficialDocumentNum(reqDto.getOfficialDocumentNum());//SimpleFieldAssign//sourceId:1312786_1
                batchQueryVagueQueryOfficialDocumentReq.setReceiveRange(reqDto.getReceiveRange());//SimpleFieldAssign//sourceId:1312787_1
                batchQueryVagueQueryOfficialDocumentReq.setIsOpenWorkTask(reqDto.getIsOpenWorkTask());//SimpleFieldAssign//sourceId:1312788_1
                batchQueryVagueQueryOfficialDocumentReq.setWorkTaskIsArrange(reqDto.getWorkTaskIsArrange());//SimpleFieldAssign//sourceId:1312789_1
                batchQueryVagueQueryOfficialDocumentReq.setCreateTime(reqDto.getCreateTime());//SimpleFieldAssign//sourceId:1312790_1
            }

            /*3-9-01批量查询模糊查公文[7945]   */
            Assert.isNull(batchQueryVagueQueryOfficialDocumentReq.getSpaceId(), "D3查我接收的公文列表-3-9-01批量查询模糊查公文-创建于空间ID不能为空", false);
            listOmsOfficialDocument = mOmsOfficialDocumentService.batchQueryVagueQueryOfficialDocument(batchQueryVagueQueryOfficialDocumentReq)/*vcase invoke 本地 method 方法调用;*/;


            listOmsOfficialDocument_1 = listOmsOfficialDocument;
        }

        QueryMyReceiveOfficialDocumentListRespDto retData = new QueryMyReceiveOfficialDocumentListRespDto();
        retData.setMyReceiveOfficialDocumentList(listOmsOfficialDocument_1.stream().map(item -> BeanUtil.toBean(item, MyReceiveOfficialDocumentDto.class)).collect(Collectors.toList()));//objList-to-objLists//sourceId:1312814_1


        return retData;
    }

    /**
     * D3查询公文详情[7932]
     * gen by moon at 5/27/2024, 10:31:13 PM
     */
    @Trace(operationName = "D3查询公文详情")
    @Tags({@Tag(key = "参数", value = "arg[0]"),
            @Tag(key = "返回值", value = "returnedObj")})
    @Transactional(rollbackFor = Exception.class)
    @Override
    public QueryOfficialDocumentDetailRespDto queryOfficialDocumentDetail(QueryOfficialDocumentDetailReqDto reqDto) {


        QueryOfficialDocumentDetailComRespDto queryOfficialDocumentDetailComRespDto_1 = null;
        QueryDocumentDetailComRespDto queryDocumentDetailComRespDto_1 = null;
        QueryUnstructuredRelationshipInstanceListComRespDto queryUnstructuredRelationshipInstanceListComRespDto_1 = null;
//virtualUsage D3-9查询公文详情(公共)  53787
        QueryOfficialDocumentDetailComRespDto queryOfficialDocumentDetailComRespDto = null;
        QueryOfficialDocumentDetailComReqDto queryOfficialDocumentDetailComReqDto = new QueryOfficialDocumentDetailComReqDto();
        queryOfficialDocumentDetailComReqDto.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1312304_1_53787
        if (reqDto != null) {
            queryOfficialDocumentDetailComReqDto.setOfficialDocumentId(reqDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1312298_1_53787
        }

        /*D3-9查询公文详情(公共)[7930]   */
        Assert.isNull(queryOfficialDocumentDetailComReqDto.getOfficialDocumentId(), "D3查询公文详情-D3-9查询公文详情(公共)-公文ID不能为空", false);
        Assert.isNull(queryOfficialDocumentDetailComReqDto.getSpaceId(), "D3查询公文详情-D3-9查询公文详情(公共)-创建于空间ID不能为空", false);
        queryOfficialDocumentDetailComRespDto = queryOfficialDocumentDetailCom(queryOfficialDocumentDetailComReqDto)/*vcase invoke 同服务,同domain*/;


        queryOfficialDocumentDetailComRespDto_1 = queryOfficialDocumentDetailComRespDto;
        if ((queryOfficialDocumentDetailComRespDto != null && queryOfficialDocumentDetailComRespDto.getOfficialDocumentFileAddress() != null)) {
            //if(D3-9查询公文详情(公共).公文文件地址 值不等于空 )  53788

            QueryUnstructuredRelationshipDetailComRespDto queryUnstructuredRelationshipDetailComRespDto = null;
            QueryUnstructuredRelationshipDetailComReqDto queryUnstructuredRelationshipDetailComReqDto = new QueryUnstructuredRelationshipDetailComReqDto();
            queryUnstructuredRelationshipDetailComReqDto.setOwnTableTypeCode("OMS_OFFICIAL_DOCUMENT");//sourceId:1823156_1_69258
            queryUnstructuredRelationshipDetailComReqDto.setDocUseType("OFFICIAL_DOCUMENT_FILE");//sourceId:1823153_1_69258
            queryUnstructuredRelationshipDetailComReqDto.setDocUseSceneCode("WORK_TASKS");//sourceId:1823155_1_69258
            queryUnstructuredRelationshipDetailComReqDto.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1823158_1_69258
            if (reqDto != null) {
                queryUnstructuredRelationshipDetailComReqDto.setOwnEntityId(reqDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1823157_1_69258
            }

            /*D2查询文档关系详情(公共)[9670]   */
            Assert.isNull(queryUnstructuredRelationshipDetailComReqDto.getOwnEntityId(), "D3查询公文详情-D2查询文档关系详情(公共)-归属内容主键ID不能为空", false);
            Assert.isNull(queryUnstructuredRelationshipDetailComReqDto.getOwnTableTypeCode(), "D3查询公文详情-D2查询文档关系详情(公共)-归属内容类型编码不能为空", false);
            Assert.isNull(queryUnstructuredRelationshipDetailComReqDto.getDocUseType(), "D3查询公文详情-D2查询文档关系详情(公共)-文档用途类型不能为空", false);
            Assert.isNull(queryUnstructuredRelationshipDetailComReqDto.getDocUseSceneCode(), "D3查询公文详情-D2查询文档关系详情(公共)-文档应用业务场景不能为空", false);
            Assert.isNull(queryUnstructuredRelationshipDetailComReqDto.getSpaceId(), "D3查询公文详情-D2查询文档关系详情(公共)-创建于空间ID不能为空", false);
            queryUnstructuredRelationshipDetailComRespDto = unstructuredDataService.queryUnstructuredRelationshipDetailCom(queryUnstructuredRelationshipDetailComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;


            QueryDocumentDetailComRespDto queryDocumentDetailComRespDto = null;
            if (queryUnstructuredRelationshipDetailComRespDto != null) {
                QueryDocumentDetailComReqDto queryDocumentDetailComReqDto = new QueryDocumentDetailComReqDto();
                if (queryUnstructuredRelationshipDetailComRespDto != null) {
                    queryDocumentDetailComReqDto.setUnstructuredDataId(queryUnstructuredRelationshipDetailComRespDto.getUnstructuredDataId());//SimpleFieldAssign//sourceId:1313526_1_53790
                }

                /*D2查公文文档名称等[3168]   */
                Assert.isNull(queryDocumentDetailComReqDto.getUnstructuredDataId(), "D3查询公文详情-D2查公文文档名称等-文档ID不能为空", false);
                queryDocumentDetailComRespDto = unstructuredDataService.queryDocumentDetailCom(queryDocumentDetailComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;


                queryDocumentDetailComRespDto_1 = queryDocumentDetailComRespDto;
            }
        }
        if ((queryOfficialDocumentDetailComRespDto != null && queryOfficialDocumentDetailComRespDto.getAnnexAddress() != null)) {
            //if(D3-9查询公文详情(公共).附件地址 值不等于空 )  53793

            QueryUnstructuredRelationshipInstanceListComRespDto queryUnstructuredRelationshipInstanceListComRespDto = null;
            QueryUnstructuredRelationshipInstanceListComReqDto queryUnstructuredRelationshipInstanceListComReqDto = new QueryUnstructuredRelationshipInstanceListComReqDto();
            queryUnstructuredRelationshipInstanceListComReqDto.setDocUseSceneCode("WORK_TASKS");//sourceId:1823185_1_69259
            queryUnstructuredRelationshipInstanceListComReqDto.setDocUseType("OFFICIAL_DOCUMENT_ANNEX");//sourceId:1823186_1_69259
            queryUnstructuredRelationshipInstanceListComReqDto.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1823187_1_69259
            if (reqDto != null) {
                queryUnstructuredRelationshipInstanceListComReqDto.setOwnEntityId(reqDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1823312_1_69259
            }

            /*D2查询文档关系实例列表(公共)[8781]   */
            Assert.isNull(queryUnstructuredRelationshipInstanceListComReqDto.getOwnEntityId(), "D3查询公文详情-D2查询文档关系实例列表(公共)-归属内容主键ID不能为空", false);
            Assert.isNull(queryUnstructuredRelationshipInstanceListComReqDto.getDocUseSceneCode(), "D3查询公文详情-D2查询文档关系实例列表(公共)-文档应用业务场景不能为空", false);
            Assert.isNull(queryUnstructuredRelationshipInstanceListComReqDto.getDocUseType(), "D3查询公文详情-D2查询文档关系实例列表(公共)-文档用途类型不能为空", false);
            Assert.isNull(queryUnstructuredRelationshipInstanceListComReqDto.getSpaceId(), "D3查询公文详情-D2查询文档关系实例列表(公共)-创建于空间ID不能为空", false);
            queryUnstructuredRelationshipInstanceListComRespDto = unstructuredDataService.queryUnstructuredRelationshipInstanceListCom(queryUnstructuredRelationshipInstanceListComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;


            queryUnstructuredRelationshipInstanceListComRespDto_1 = queryUnstructuredRelationshipInstanceListComRespDto;
        }
        QueryOfficialDocumentDetailRespDto retData = new QueryOfficialDocumentDetailRespDto();
        if (queryOfficialDocumentDetailComRespDto_1 != null) {
            retData.setOfficialDocumentId(queryOfficialDocumentDetailComRespDto_1.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1312347_1
            retData.setOfficialDocumentName(queryOfficialDocumentDetailComRespDto_1.getOfficialDocumentName());//SimpleFieldAssign//sourceId:1312348_1
            retData.setOfficialDocumentNum(queryOfficialDocumentDetailComRespDto_1.getOfficialDocumentNum());//SimpleFieldAssign//sourceId:1312349_1
            retData.setNotificationDescription(queryOfficialDocumentDetailComRespDto_1.getNotificationDescription());//SimpleFieldAssign//sourceId:1420044_1
            retData.setReceiveRange(queryOfficialDocumentDetailComRespDto_1.getReceiveRange());//SimpleFieldAssign//sourceId:1312350_1
            retData.setOfficialDocumentFileAddress(queryOfficialDocumentDetailComRespDto_1.getOfficialDocumentFileAddress());//SimpleFieldAssign//sourceId:1313093_1
            retData.setReceiveInductionId(queryOfficialDocumentDetailComRespDto_1.getReceiveInductionId());//SimpleFieldAssign//sourceId:1312351_1
            retData.setNotificationType(queryOfficialDocumentDetailComRespDto_1.getNotificationType());//SimpleFieldAssign//sourceId:1418244_1
            retData.setRemindLevel(queryOfficialDocumentDetailComRespDto_1.getRemindLevel());//SimpleFieldAssign//sourceId:1312352_1
            retData.setIsOpenWorkTask(queryOfficialDocumentDetailComRespDto_1.getIsOpenWorkTask());//SimpleFieldAssign//sourceId:1312353_1
            retData.setWorkTaskIsArrange(queryOfficialDocumentDetailComRespDto_1.getWorkTaskIsArrange());//SimpleFieldAssign//sourceId:1312354_1
            retData.setArrangeWorkTaskId(queryOfficialDocumentDetailComRespDto_1.getArrangeWorkTaskId());//SimpleFieldAssign//sourceId:1419946_1
            retData.setArrangeWorkTaskTypeCode(queryOfficialDocumentDetailComRespDto_1.getArrangeWorkTaskTypeCode());//SimpleFieldAssign//sourceId:1419947_1
            retData.setAppointWorkTaskArrangeInductionId(queryOfficialDocumentDetailComRespDto_1.getAppointWorkTaskArrangeInductionId());//SimpleFieldAssign//sourceId:1312355_1
            retData.setSubjectLifeCycle(queryOfficialDocumentDetailComRespDto_1.getSubjectLifeCycle());//SimpleFieldAssign//sourceId:1312356_1
            retData.setCreateInductionId(queryOfficialDocumentDetailComRespDto_1.getCreateInductionId());//SimpleFieldAssign//sourceId:1313618_1
            retData.setCreateTime(queryOfficialDocumentDetailComRespDto_1.getCreateTime());//SimpleFieldAssign//sourceId:1313619_1
            retData.setOperationInductionId(queryOfficialDocumentDetailComRespDto_1.getOperationInductionId());//SimpleFieldAssign//sourceId:1312357_1
            retData.setOperateTime(queryOfficialDocumentDetailComRespDto_1.getOperateTime());//SimpleFieldAssign//sourceId:1312358_1
        }
        if (queryDocumentDetailComRespDto_1 != null) {
            retData.setUnstructuredDataId(queryDocumentDetailComRespDto_1.getUnstructuredDataId());//SimpleFieldAssign//sourceId:1313547_1
            retData.setUnstructuredDataName(queryDocumentDetailComRespDto_1.getUnstructuredDataName());//SimpleFieldAssign//sourceId:1313548_1
            retData.setFileSize(queryDocumentDetailComRespDto_1.getFileSize());//SimpleFieldAssign//sourceId:1313549_1
            retData.setPostfix(queryDocumentDetailComRespDto_1.getPostfix());//SimpleFieldAssign//sourceId:1313550_1
            retData.setUnstructuredDataType(queryDocumentDetailComRespDto_1.getUnstructuredDataType());//SimpleFieldAssign//sourceId:1313551_1
        }
        if (queryUnstructuredRelationshipInstanceListComRespDto_1 != null) {
            retData.setAnnexList(queryUnstructuredRelationshipInstanceListComRespDto_1.getUnstructuredRelationshipList().stream().map(item -> BeanUtil.toBean(item, AnnexDto.class)).collect(Collectors.toList()));//objList-to-objLists//sourceId:1312359_1
        }


        return retData;
    }

    /**
     * D3查接收的公文列表[7943]
     * gen by moon at 1/27/2024, 10:42:05 PM
     */
    @Trace(operationName = "D3查接收的公文列表")
    @Tags({@Tag(key = "参数", value = "arg[0]"),
            @Tag(key = "返回值", value = "returnedObj")})
    @Transactional(rollbackFor = Exception.class)
    @Override
    public QueryReceiveOfficialDocumentListRespDto queryReceiveOfficialDocumentList(QueryReceiveOfficialDocumentListReqDto reqDto) {


        List<OmsOfficialDocument> listOmsOfficialDocument_1 = new ArrayList<>();
//virtualUsage D3分析通知类型行为类型(公共)  60330
        AnalysisNotificationTypeBehaviorTypeComRespDto analysisNotificationTypeBehaviorTypeComRespDto = null;
        AnalysisNotificationTypeBehaviorTypeComReqDto analysisNotificationTypeBehaviorTypeComReqDto = new AnalysisNotificationTypeBehaviorTypeComReqDto();
        if (reqDto != null) {
            analysisNotificationTypeBehaviorTypeComReqDto.setNotificationType(reqDto.getNotificationType());//SimpleFieldAssign//sourceId:1510987_1_60330
        }

        /*D3分析通知类型行为类型(公共)[8362]   */

        analysisNotificationTypeBehaviorTypeComRespDto = analysisNotificationTypeBehaviorTypeCom(analysisNotificationTypeBehaviorTypeComReqDto)/*vcase invoke 同服务,同domain*/;


        if ((reqDto != null && reqDto.getEntityId() != null)) {
            //if(D3查接收的公文列表.通道归属主体ID 值不等于空 )  53627

            ImplementChannelTypeAnalyzeComRespDto implementChannelTypeAnalyzeComRespDto = null;
            ImplementChannelTypeAnalyzeComReqDto implementChannelTypeAnalyzeComReqDto = new ImplementChannelTypeAnalyzeComReqDto();
            if (reqDto != null) {
                implementChannelTypeAnalyzeComReqDto.setNewTableTypeCode(reqDto.getTableTypeCode());//SimpleFieldAssign//sourceId:1333913_1_54230
            }

            /*D2执行通道类型分析(公共)[7982]   */
            Assert.isNull(implementChannelTypeAnalyzeComReqDto.getNewTableTypeCode(), "D3查接收的公文列表-D2执行通道类型分析(公共)-通道归属主体内容类型编码不能为空", false);
            implementChannelTypeAnalyzeComRespDto = fwCompMessageClient.implementChannelTypeAnalyzeCom(implementChannelTypeAnalyzeComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;


            QueryChannelDetailComRespDto queryChannelDetailComRespDto = null;
            if (implementChannelTypeAnalyzeComRespDto != null) {
                QueryChannelDetailComReqDto queryChannelDetailComReqDto = new QueryChannelDetailComReqDto();
                queryChannelDetailComReqDto.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1313673_1_53629
                if (reqDto != null) {
                    queryChannelDetailComReqDto.setEntityId(reqDto.getEntityId());//SimpleFieldAssign//sourceId:1313672_1_53629
                    queryChannelDetailComReqDto.setTableTypeCode(reqDto.getTableTypeCode());//SimpleFieldAssign//sourceId:1331874_1_53629
                }
                if (implementChannelTypeAnalyzeComRespDto != null) {
                    queryChannelDetailComReqDto.setChannelTypeCode(implementChannelTypeAnalyzeComRespDto.getChannelTypeCode());//SimpleFieldAssign//sourceId:1331873_1_53629
                }

                /*D2查询通道详情(公共)[7101]   */
                Assert.isNull(queryChannelDetailComReqDto.getChannelTypeCode(), "D3查接收的公文列表-D2查询通道详情(公共)-通道类型编码不能为空", false);
                Assert.isNull(queryChannelDetailComReqDto.getSpaceId(), "D3查接收的公文列表-D2查询通道详情(公共)-创建于空间ID不能为空", false);
                queryChannelDetailComRespDto = fwCompMessageClient.queryChannelDetailCom(queryChannelDetailComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;


            }
            QueryOfficialDocumentMsgListComRespDto queryOfficialDocumentMsgListComRespDto = null;
            if (queryChannelDetailComRespDto != null && analysisNotificationTypeBehaviorTypeComRespDto != null) {
                QueryOfficialDocumentMsgListComReqDto queryOfficialDocumentMsgListComReqDto = new QueryOfficialDocumentMsgListComReqDto();
                if (queryChannelDetailComRespDto != null) {
                    queryOfficialDocumentMsgListComReqDto.setMessageChannelId(queryChannelDetailComRespDto.getMessageChannelId());//SimpleFieldAssign//sourceId:1313665_1_53630
                }
                if (analysisNotificationTypeBehaviorTypeComRespDto != null) {
                    queryOfficialDocumentMsgListComReqDto.setBehaviorTypeCode(analysisNotificationTypeBehaviorTypeComRespDto.getBehaviorTypeCode());//SimpleFieldAssign//sourceId:1510327_1_53630
                }

                /*D2查公文消息列表(公共)[7944]   */

                queryOfficialDocumentMsgListComRespDto = fwCompMessageClient.queryOfficialDocumentMsgListCom(queryOfficialDocumentMsgListComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;


            }
            List<OmsOfficialDocument> listOmsOfficialDocument = new ArrayList<>();
            if (queryOfficialDocumentMsgListComRespDto != null) {
                BatchQueryVagueQueryOfficialDocumentReq batchQueryVagueQueryOfficialDocumentReq = new BatchQueryVagueQueryOfficialDocumentReq();
                batchQueryVagueQueryOfficialDocumentReq.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1312791_1_53631
                if (queryOfficialDocumentMsgListComRespDto != null && queryOfficialDocumentMsgListComRespDto.getOfficialDocumentMsgList() != null && !CollectionUtil.isEmpty(queryOfficialDocumentMsgListComRespDto.getOfficialDocumentMsgList())) {
                    batchQueryVagueQueryOfficialDocumentReq.setOfficialDocumentList(queryOfficialDocumentMsgListComRespDto.getOfficialDocumentMsgList().stream().map(item -> item.getEntityId())
                            .collect(Collectors.toList()));/*list-to-strings*///sourceId:1312784_1_53631
                }
                if (reqDto != null) {
                    batchQueryVagueQueryOfficialDocumentReq.setOfficialDocumentName(reqDto.getOfficialDocumentName());//SimpleFieldAssign//sourceId:1312785_1_53631
                    batchQueryVagueQueryOfficialDocumentReq.setOfficialDocumentNum(reqDto.getOfficialDocumentNum());//SimpleFieldAssign//sourceId:1312786_1_53631
                    batchQueryVagueQueryOfficialDocumentReq.setReceiveRange(reqDto.getReceiveRange());//SimpleFieldAssign//sourceId:1312787_1_53631
                    batchQueryVagueQueryOfficialDocumentReq.setNotificationType(reqDto.getNotificationType());//SimpleFieldAssign//sourceId:1418258_1_53631
                    batchQueryVagueQueryOfficialDocumentReq.setIsOpenWorkTask(reqDto.getIsOpenWorkTask());//SimpleFieldAssign//sourceId:1312788_1_53631
                    batchQueryVagueQueryOfficialDocumentReq.setWorkTaskIsArrange(reqDto.getWorkTaskIsArrange());//SimpleFieldAssign//sourceId:1312789_1_53631
                    batchQueryVagueQueryOfficialDocumentReq.setCreateTime(reqDto.getCreateTime());//SimpleFieldAssign//sourceId:1312790_1_53631
                }

                /*3-9-01批量查询模糊查公文[7945]   */
                Assert.isNull(batchQueryVagueQueryOfficialDocumentReq.getSpaceId(), "D3查接收的公文列表-3-9-01批量查询模糊查公文-创建于空间ID不能为空", false);
                listOmsOfficialDocument = mOmsOfficialDocumentService.batchQueryVagueQueryOfficialDocument(batchQueryVagueQueryOfficialDocumentReq)/*vcase invoke 本地 method 方法调用;*/;


                listOmsOfficialDocument_1 = listOmsOfficialDocument;
            }
        } else if ((reqDto != null && reqDto.getEntityId() == null)) {
            //elseif(D3查接收的公文列表.通道归属主体ID 值等于空 )  53628

//ModelCode: receptionService
            ImplementGainInParameterFieldsRespDto receptionServiceRes = null;
            ImplementGainInParameterFieldsReqDto receptionServiceReq = new ImplementGainInParameterFieldsReqDto();
            receptionServiceReq.setOriginalRoleMemberId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecOriginalRoleMemberId());//CURRENT_ORIGINAL_ROLE_MEMBERID//sourceId:1314346_1_53633

            /*M3约定当前身份人员ID[6965]  用于特殊方法接收上游入参。 */
            Assert.isNull(receptionServiceReq.getOriginalRoleMemberId(), "D3查接收的公文列表-M3约定当前身份人员ID-身份人员ID不能为空", false);
            receptionServiceRes = nbOfficialDocument.implementGainInParameterFields(receptionServiceReq);


            QueryOfficialDocumentMsgListComRespDto queryOfficialDocumentMsgListComRespDto_2 = null;
            if (analysisNotificationTypeBehaviorTypeComRespDto != null) {
                QueryOfficialDocumentMsgListComReqDto queryOfficialDocumentMsgListComReqDto_1 = new QueryOfficialDocumentMsgListComReqDto();
                if (receptionServiceRes != null) {
                    queryOfficialDocumentMsgListComReqDto_1.setOriginalRoleMemberId(receptionServiceRes.getOriginalRoleMemberId());//SimpleFieldAssign//sourceId:1313664_1_53632
                }
                if (analysisNotificationTypeBehaviorTypeComRespDto != null) {
                    queryOfficialDocumentMsgListComReqDto_1.setBehaviorTypeCode(analysisNotificationTypeBehaviorTypeComRespDto.getBehaviorTypeCode());//SimpleFieldAssign//sourceId:1510327_1_53632
                }

                /*D2查公文消息列表(公共)[7944]   */

                queryOfficialDocumentMsgListComRespDto_2 = fwCompMessageClient.queryOfficialDocumentMsgListCom(queryOfficialDocumentMsgListComReqDto_1).getData()/*vcase invoke 跨dubbo调用;*/;


            }
            List<OmsOfficialDocument> listOmsOfficialDocument_2 = new ArrayList<>();
            if (queryOfficialDocumentMsgListComRespDto_2 != null) {
                BatchQueryVagueQueryOfficialDocumentReq batchQueryVagueQueryOfficialDocumentReq_1 = new BatchQueryVagueQueryOfficialDocumentReq();
                batchQueryVagueQueryOfficialDocumentReq_1.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1312791_1_53634
                if (queryOfficialDocumentMsgListComRespDto_2 != null && queryOfficialDocumentMsgListComRespDto_2.getOfficialDocumentMsgList() != null && !CollectionUtil.isEmpty(queryOfficialDocumentMsgListComRespDto_2.getOfficialDocumentMsgList())) {
                    batchQueryVagueQueryOfficialDocumentReq_1.setOfficialDocumentList(queryOfficialDocumentMsgListComRespDto_2.getOfficialDocumentMsgList().stream().map(item -> item.getEntityId())
                            .collect(Collectors.toList()));/*list-to-strings*///sourceId:1312784_1_53634
                }
                if (reqDto != null) {
                    batchQueryVagueQueryOfficialDocumentReq_1.setOfficialDocumentName(reqDto.getOfficialDocumentName());//SimpleFieldAssign//sourceId:1312785_1_53634
                    batchQueryVagueQueryOfficialDocumentReq_1.setOfficialDocumentNum(reqDto.getOfficialDocumentNum());//SimpleFieldAssign//sourceId:1312786_1_53634
                    batchQueryVagueQueryOfficialDocumentReq_1.setReceiveRange(reqDto.getReceiveRange());//SimpleFieldAssign//sourceId:1312787_1_53634
                    batchQueryVagueQueryOfficialDocumentReq_1.setNotificationType(reqDto.getNotificationType());//SimpleFieldAssign//sourceId:1418258_1_53634
                    batchQueryVagueQueryOfficialDocumentReq_1.setIsOpenWorkTask(reqDto.getIsOpenWorkTask());//SimpleFieldAssign//sourceId:1312788_1_53634
                    batchQueryVagueQueryOfficialDocumentReq_1.setWorkTaskIsArrange(reqDto.getWorkTaskIsArrange());//SimpleFieldAssign//sourceId:1312789_1_53634
                    batchQueryVagueQueryOfficialDocumentReq_1.setCreateTime(reqDto.getCreateTime());//SimpleFieldAssign//sourceId:1312790_1_53634
                }

                /*3-9-01批量查询模糊查公文[7945]   */
                Assert.isNull(batchQueryVagueQueryOfficialDocumentReq_1.getSpaceId(), "D3查接收的公文列表-3-9-01批量查询模糊查公文-创建于空间ID不能为空", false);
                listOmsOfficialDocument_2 = mOmsOfficialDocumentService.batchQueryVagueQueryOfficialDocument(batchQueryVagueQueryOfficialDocumentReq_1)/*vcase invoke 本地 method 方法调用;*/;


                listOmsOfficialDocument_1 = listOmsOfficialDocument_2;
            }
        }
        QueryReceiveOfficialDocumentListRespDto retData = new QueryReceiveOfficialDocumentListRespDto();
        retData.setMyReceiveOfficialDocumentList(listOmsOfficialDocument_1.stream().map(item -> BeanUtil.toBean(item, MyReceiveOfficialDocumentDto.class)).collect(Collectors.toList()));//objList-to-objLists//sourceId:1312814_1


        return retData;
    }

    /**
     * D3执行回写公文安排的任务(公共)[7997]
     * gen by moon at 12/3/2023, 1:08:27 PM
     */
    @Trace(operationName = "D3执行回写公文安排的任务(公共)")
    @Tags({@Tag(key = "参数", value = "arg[0]"),
            @Tag(key = "返回值", value = "returnedObj")})
    @Transactional(rollbackFor = Exception.class)
    @Override
    public ImplementWriteBackOffcialDocArrangeTaskComRespDto implementWriteBackOffcialDocArrangeTaskCom(ImplementWriteBackOffcialDocArrangeTaskComReqDto reqDto) {


        //virtualUsage D3-9查公文详情(用于回写安排的任务)  54429
        QueryOfficialDocumentDetailComRespDto queryOfficialDocumentDetailComRespDto = null;
        QueryOfficialDocumentDetailComReqDto queryOfficialDocumentDetailComReqDto = new QueryOfficialDocumentDetailComReqDto();
        queryOfficialDocumentDetailComReqDto.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1346264_1_54429
        if (reqDto != null) {
            queryOfficialDocumentDetailComReqDto.setOfficialDocumentId(reqDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1346258_1_54429
        }

        /*D3-9查公文详情(用于回写安排的任务)[7930]   */
        Assert.isNull(queryOfficialDocumentDetailComReqDto.getOfficialDocumentId(), "D3执行回写公文安排的任务(公共)-D3-9查公文详情(用于回写安排的任务)-公文ID不能为空", false);
        Assert.isNull(queryOfficialDocumentDetailComReqDto.getSpaceId(), "D3执行回写公文安排的任务(公共)-D3-9查公文详情(用于回写安排的任务)-创建于空间ID不能为空", false);
        queryOfficialDocumentDetailComRespDto = queryOfficialDocumentDetailCom(queryOfficialDocumentDetailComReqDto)/*vcase invoke 同服务,同domain*/;


        if ((queryOfficialDocumentDetailComRespDto != null && queryOfficialDocumentDetailComRespDto.getOfficialDocumentId() != null)) {
            //if(D3-9查公文详情(用于回写安排的任务).公文ID 值不等于空 )  54430

            UpdateOfficialDocumentBodyComRespDto updateOfficialDocumentBodyComRespDto = null;
            if (queryOfficialDocumentDetailComRespDto != null) {
                UpdateOfficialDocumentBodyComReqDto updateOfficialDocumentBodyComReqDto = new UpdateOfficialDocumentBodyComReqDto();
                updateOfficialDocumentBodyComReqDto.setWorkTaskIsArrange("TRUE");//sourceId:1346301_1_54431
                if (queryOfficialDocumentDetailComRespDto != null) {
                    updateOfficialDocumentBodyComReqDto.setOfficialDocumentId(queryOfficialDocumentDetailComRespDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1346291_1_54431
                }
                if (reqDto != null) {
                    updateOfficialDocumentBodyComReqDto.setArrangeWorkTaskId(reqDto.getArrangeWorkTaskId());//SimpleFieldAssign//sourceId:1346309_1_54431
                    updateOfficialDocumentBodyComReqDto.setArrangeWorkTaskTypeCode(reqDto.getArrangeWorkTaskTypeCode());//SimpleFieldAssign//sourceId:1346308_1_54431
                }

                /*D3-9修改公文主体(公共)[7923]   */
                Assert.isNull(updateOfficialDocumentBodyComReqDto.getOfficialDocumentId(), "D3执行回写公文安排的任务(公共)-D3-9修改公文主体(公共)-公文ID不能为空", false);
                Assert.isNull(updateOfficialDocumentBodyComReqDto.getArrangeWorkTaskId(), "D3执行回写公文安排的任务(公共)-D3-9修改公文主体(公共)-安排的工作任务ID不能为空", false);
                Assert.isNull(updateOfficialDocumentBodyComReqDto.getArrangeWorkTaskTypeCode(), "D3执行回写公文安排的任务(公共)-D3-9修改公文主体(公共)-安排的工作任务类型编码不能为空", false);
                Assert.isNull(updateOfficialDocumentBodyComReqDto.getWorkTaskIsArrange(), "D3执行回写公文安排的任务(公共)-D3-9修改公文主体(公共)-工作任务是否已安排不能为空", false);
                updateOfficialDocumentBodyComRespDto = updateOfficialDocumentBodyCom(updateOfficialDocumentBodyComReqDto)/*vcase invoke 同服务,同domain*/;


            }
            QueryMessageDetailComRespDto queryMessageDetailComRespDto = null;
            QueryMessageDetailComReqDto queryMessageDetailComReqDto = new QueryMessageDetailComReqDto();
            queryMessageDetailComReqDto.setMessageTemplateCode("ARRANGE_WORK_TASK_INSTRUCT");//CUSTOM_CONVENTION//sourceId:1369494_1_55221
            queryMessageDetailComReqDto.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1369493_1_55221
            if (reqDto != null) {
                queryMessageDetailComReqDto.setEntityId(reqDto.getOfficialDocumentId());//SimpleFieldAssign//sourceId:1369490_1_55221
            }

            /*D2-查询消息详情(公共)[7526]   */
            Assert.isNull(queryMessageDetailComReqDto.getEntityId(), "D3执行回写公文安排的任务(公共)-D2-查询消息详情(公共)-归属内容ID不能为空", false);
            Assert.isNull(queryMessageDetailComReqDto.getMessageTemplateCode(), "D3执行回写公文安排的任务(公共)-D2-查询消息详情(公共)-消息模板标识不能为空", false);
            Assert.isNull(queryMessageDetailComReqDto.getSpaceId(), "D3执行回写公文安排的任务(公共)-D2-查询消息详情(公共)-创建于空间ID不能为空", false);
            queryMessageDetailComRespDto = fwCompMessageClient.queryMessageDetailCom(queryMessageDetailComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;


            if ((queryMessageDetailComRespDto != null && queryMessageDetailComRespDto.getMessageId() != null && queryMessageDetailComRespDto != null && queryMessageDetailComRespDto.getIsHandle() != null && queryMessageDetailComRespDto.getIsHandle().equals("FALSE"))) {
                //if((D2-查询消息详情(公共).消息ID 值不等于空  and D2-查询消息详情(公共).是否已处理 等于 否))  55233

                ImplementMsgDisposeStateComRespDto implementMsgDisposeStateComRespDto = null;
                if (queryMessageDetailComRespDto != null) {
                    ImplementMsgDisposeStateComReqDto implementMsgDisposeStateComReqDto = new ImplementMsgDisposeStateComReqDto();
                    implementMsgDisposeStateComReqDto.setIsHandle("TRUE");//sourceId:1369452_1_55234
                    if (queryMessageDetailComRespDto != null) {
                        implementMsgDisposeStateComReqDto.setMessageId(queryMessageDetailComRespDto.getMessageId());//SimpleFieldAssign//sourceId:1369451_1_55234
                    }

                    /*D2-执行消息处理状态(公共)[7544]   */
                    Assert.isNull(implementMsgDisposeStateComReqDto.getMessageId(), "D3执行回写公文安排的任务(公共)-D2-执行消息处理状态(公共)-消息ID不能为空", false);
                    Assert.isNull(implementMsgDisposeStateComReqDto.getIsHandle(), "D3执行回写公文安排的任务(公共)-D2-执行消息处理状态(公共)-是否已处理不能为空", false);
                    implementMsgDisposeStateComRespDto = fwCompMessageClient.implementMsgDisposeStateCom(implementMsgDisposeStateComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;


                }
            }
        }
        ImplementWriteBackOffcialDocArrangeTaskComRespDto retData = new ImplementWriteBackOffcialDocArrangeTaskComRespDto();


        return retData;
    }

    /**
     * D3查询未安排的公文列表[8062]
     * gen by moon at 12/15/2023, 2:41:37 PM
     */
    @Trace(operationName = "D3查询未安排的公文列表")
    @Tags({@Tag(key = "参数", value = "arg[0]"),
            @Tag(key = "返回值", value = "returnedObj")})
    @Transactional(rollbackFor = Exception.class)
    @Override
    public QueryUnscheduledOfficialDocListRespDto queryUnscheduledOfficialDocList(QueryUnscheduledOfficialDocListReqDto reqDto) {


        QueryOfficialDocumentBodyListComRespDto queryOfficialDocumentBodyListComRespDto_1 = null;
//步骤0: D3查询公文主体列表(公共) - queryOfficialDocumentBodyListCom
        QueryOfficialDocumentBodyListComRespDto queryOfficialDocumentBodyListComRespDto = null;
        QueryOfficialDocumentBodyListComReqDto queryOfficialDocumentBodyListComReqDto = new QueryOfficialDocumentBodyListComReqDto();
        queryOfficialDocumentBodyListComReqDto.setIsOpenWorkTask("TRUE");//sourceId:1368854_1
        queryOfficialDocumentBodyListComReqDto.setWorkTaskIsArrange("FALSE");//sourceId:1368855_1
        queryOfficialDocumentBodyListComReqDto.setSubjectLifeCycle("CURRENTLY_VALID");//sourceId:1368857_1
        if (reqDto != null) {
            queryOfficialDocumentBodyListComReqDto.setAppointWorkTaskArrangeInductionId(reqDto.getAppointWorkTaskArrangeInductionId());//SimpleFieldAssign//sourceId:1368859_1
            queryOfficialDocumentBodyListComReqDto.setNotificationType(reqDto.getNotificationType());//SimpleFieldAssign//sourceId:1418254_1
        }

        /*D3查询公文主体列表(公共)[8063]   */
        Assert.isNull(queryOfficialDocumentBodyListComReqDto.getAppointWorkTaskArrangeInductionId(), "D3查询未安排的公文列表-D3查询公文主体列表(公共)-指定工作任务安排人就职记录ID不能为空", false);
        Assert.isNull(queryOfficialDocumentBodyListComReqDto.getIsOpenWorkTask(), "D3查询未安排的公文列表-D3查询公文主体列表(公共)-是否开启工作任务不能为空", false);
        Assert.isNull(queryOfficialDocumentBodyListComReqDto.getWorkTaskIsArrange(), "D3查询未安排的公文列表-D3查询公文主体列表(公共)-工作任务是否已安排不能为空", false);
        Assert.isNull(queryOfficialDocumentBodyListComReqDto.getSubjectLifeCycle(), "D3查询未安排的公文列表-D3查询公文主体列表(公共)-主体生命周期不能为空", false);
        queryOfficialDocumentBodyListComRespDto = queryOfficialDocumentBodyListCom(queryOfficialDocumentBodyListComReqDto)/*vcase invoke 同服务,同domain*/;


        queryOfficialDocumentBodyListComRespDto_1 = queryOfficialDocumentBodyListComRespDto;

        QueryUnscheduledOfficialDocListRespDto retData = new QueryUnscheduledOfficialDocListRespDto();
        if (queryOfficialDocumentBodyListComRespDto_1 != null) {
            retData.setOfficialDocumentList(queryOfficialDocumentBodyListComRespDto_1.getOfficialDocumentList().stream().map(item -> BeanUtil.toBean(item, OfficialDocumentDto.class)).collect(Collectors.toList()));//objList-to-objLists//sourceId:1368861_1
        }


        return retData;
    }

    /**
     * D3查询公文主体列表(公共)[8063]
     * gen by moon at 12/15/2023, 2:41:44 PM
     */
    @Trace(operationName = "D3查询公文主体列表(公共)")
    @Tags({@Tag(key = "参数", value = "arg[0]"),
            @Tag(key = "返回值", value = "returnedObj")})
    @Transactional(rollbackFor = Exception.class)
    @Override
    public QueryOfficialDocumentBodyListComRespDto queryOfficialDocumentBodyListCom(QueryOfficialDocumentBodyListComReqDto reqDto) {


        List<OmsOfficialDocument> listOmsOfficialDocument_1 = new ArrayList<>();
//步骤0: 3-9-01查询公文列表 - queryOfficialDocumentList
        List<OmsOfficialDocument> listOmsOfficialDocument = new ArrayList<>();
        QueryOfficialDocumentListReq queryOfficialDocumentListReq = new QueryOfficialDocumentListReq();
        queryOfficialDocumentListReq.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1368828_1
        if (reqDto != null) {
            queryOfficialDocumentListReq.setOfficialDocumentName(reqDto.getOfficialDocumentName());//SimpleFieldAssign//sourceId:1368825_1
            queryOfficialDocumentListReq.setOfficialDocumentNum(reqDto.getOfficialDocumentNum());//SimpleFieldAssign//sourceId:1368829_1
            queryOfficialDocumentListReq.setReceiveRange(reqDto.getReceiveRange());//SimpleFieldAssign//sourceId:1368831_1
            queryOfficialDocumentListReq.setNotificationType(reqDto.getNotificationType());//SimpleFieldAssign//sourceId:1418252_1
            queryOfficialDocumentListReq.setIsOpenWorkTask(reqDto.getIsOpenWorkTask());//SimpleFieldAssign//sourceId:1368832_1
            queryOfficialDocumentListReq.setWorkTaskIsArrange(reqDto.getWorkTaskIsArrange());//SimpleFieldAssign//sourceId:1368833_1
            queryOfficialDocumentListReq.setAppointWorkTaskArrangeInductionId(reqDto.getAppointWorkTaskArrangeInductionId());//SimpleFieldAssign//sourceId:1368845_1
            queryOfficialDocumentListReq.setIsArchive(reqDto.getIsArchive());//SimpleFieldAssign//sourceId:1368827_1
            queryOfficialDocumentListReq.setSubjectLifeCycle(reqDto.getSubjectLifeCycle());//SimpleFieldAssign//sourceId:1368826_1
        }

        /*3-9-01查询公文列表[7926]   */
        Assert.isNull(queryOfficialDocumentListReq.getSpaceId(), "D3查询公文主体列表(公共)-3-9-01查询公文列表-创建于空间ID不能为空", false);
        listOmsOfficialDocument = mOmsOfficialDocumentService.queryOfficialDocumentList(queryOfficialDocumentListReq)/*vcase invoke 本地 method 方法调用;*/;


        listOmsOfficialDocument_1 = listOmsOfficialDocument;

        QueryOfficialDocumentBodyListComRespDto retData = new QueryOfficialDocumentBodyListComRespDto();
        retData.setOfficialDocumentList(listOmsOfficialDocument_1.stream().map(item -> BeanUtil.toBean(item, OfficialDocumentDto.class)).collect(Collectors.toList()));//objList-to-objLists//sourceId:1368843_1


        return retData;
    }

    /**
     * D3执行通知类型消息模板分析(公共)[8153]
     * gen by moon at 1/2/2024, 12:54:39 PM
     */
    @Trace(operationName = "D3执行通知类型消息模板分析(公共)")
    @Tags({@Tag(key = "参数", value = "arg[0]"),
            @Tag(key = "返回值", value = "returnedObj")})
    @Transactional(rollbackFor = Exception.class)
    @Override
    public ImplementNotificationTypeMsgTempanAlyzeComRespDto implementNotificationTypeMsgTempanAlyzeCom(ImplementNotificationTypeMsgTempanAlyzeComReqDto reqDto) {


        ImplementTypeCodeFieldsAcceptRespDto receptionServiceRes_5 = null;
        if ((reqDto != null && reqDto.getNotificationType() != null && reqDto.getNotificationType().equals("OFFICIAL_DOCUMENT"))) {
            //if(D3执行通知类型消息模板分析(公共).通知类型 等于 公文)  56667

//ModelCode: receptionService
            ImplementTypeCodeFieldsAcceptRespDto receptionServiceRes = null;
            ImplementTypeCodeFieldsAcceptReqDto receptionServiceReq = new ImplementTypeCodeFieldsAcceptReqDto();
            receptionServiceReq.setMsgTitleTemplateSemanticEngineCode("ISSUE_OFFCIAL_DOC_TITLE");//CUSTOM_CONVENTION//sourceId:1464868_1_56673

            /*M3约定下发公文标题语义引擎模板[7735]  用于特殊方法接收上游入参。 */
            Assert.isNull(receptionServiceReq.getMsgTitleTemplateSemanticEngineCode(), "D3执行通知类型消息模板分析(公共)-M3约定下发公文标题语义引擎模板-消息标题模板引擎标识不能为空", false);
            receptionServiceRes = nbOfficialDocument.implementTypeCodeFieldsAccept(receptionServiceReq);


            if ((reqDto != null && reqDto.getReceiveRange() != null && reqDto.getReceiveRange().equals("EVERYONE"))) {
                //if(D3执行通知类型消息模板分析(公共).接收范围 等于 所有人)  56672

//ModelCode: receptionService
                ImplementTypeCodeFieldsAcceptRespDto receptionServiceRes_2 = null;
                ImplementTypeCodeFieldsAcceptReqDto receptionServiceReq_1 = new ImplementTypeCodeFieldsAcceptReqDto();
                receptionServiceReq_1.setSendMsgScene("ISSUE_OFFICIAL_DOC_SEND_EVERYONE");//sourceId:1464850_1_56674
                receptionServiceReq_1.setMessageTemplateCode("ISSUE_OFFCIAL_DOC_ORG_GROUP");//CUSTOM_CONVENTION//sourceId:1464896_1_56674

                /*M3约定下发公文给所有人[7735]  用于特殊方法接收上游入参。 */
                Assert.isNull(receptionServiceReq_1.getSendMsgScene(), "D3执行通知类型消息模板分析(公共)-M3约定下发公文给所有人-发送消息场景不能为空", false);
                Assert.isNull(receptionServiceReq_1.getMessageTemplateCode(), "D3执行通知类型消息模板分析(公共)-M3约定下发公文给所有人-消息模板标识不能为空", false);
                receptionServiceRes_2 = nbOfficialDocument.implementTypeCodeFieldsAccept(receptionServiceReq_1);


//ModelCode: receptionService
                ImplementTypeCodeFieldsAcceptRespDto receptionServiceRes_4 = null;
                ImplementTypeCodeFieldsAcceptReqDto receptionServiceReq_2 = new ImplementTypeCodeFieldsAcceptReqDto();
                if (receptionServiceRes_2 != null) {
                    receptionServiceReq_2.setSendMsgScene(receptionServiceRes_2.getSendMsgScene());//SimpleFieldAssign//sourceId:1464853_1_56675
                    receptionServiceReq_2.setMessageTemplateCode(receptionServiceRes_2.getMessageTemplateCode());//SimpleFieldAssign//sourceId:1464898_1_56675
                }
                if (receptionServiceRes != null) {
                    receptionServiceReq_2.setMsgTitleTemplateSemanticEngineCode(receptionServiceRes.getMsgTitleTemplateSemanticEngineCode());//SimpleFieldAssign//sourceId:1464870_1_56675
                }

                /*M3接收发消息业务场景[7735]  用于特殊方法接收上游入参。 */
                Assert.isNull(receptionServiceReq_2.getSendMsgScene(), "D3执行通知类型消息模板分析(公共)-M3接收发消息业务场景-发送消息场景不能为空", false);
                Assert.isNull(receptionServiceReq_2.getMessageTemplateCode(), "D3执行通知类型消息模板分析(公共)-M3接收发消息业务场景-消息模板标识不能为空", false);
                Assert.isNull(receptionServiceReq_2.getMsgTitleTemplateSemanticEngineCode(), "D3执行通知类型消息模板分析(公共)-M3接收发消息业务场景-消息标题模板引擎标识不能为空", false);
                receptionServiceRes_4 = nbOfficialDocument.implementTypeCodeFieldsAccept(receptionServiceReq_2);


                receptionServiceRes_5 = receptionServiceRes_4;
            } else if ((reqDto != null && reqDto.getReceiveRange() != null && reqDto.getReceiveRange().equals("DEPT"))) {
                //elseif(D3执行通知类型消息模板分析(公共).接收范围 等于 部门)  56676

//ModelCode: receptionService
                ImplementTypeCodeFieldsAcceptRespDto receptionServiceRes_6 = null;
                ImplementTypeCodeFieldsAcceptReqDto receptionServiceReq_3 = new ImplementTypeCodeFieldsAcceptReqDto();
                receptionServiceReq_3.setSendMsgScene("ISSUE_OFFICIAL_DOC_SEND_DEPT");//sourceId:1464855_1_56677
                receptionServiceReq_3.setMessageTemplateCode("ISSUE_OFFCIAL_DOC_DEPT_GROUP");//CUSTOM_CONVENTION//sourceId:1464900_1_56677

                /*M3约定下发公文给部门[7735]  用于特殊方法接收上游入参。 */
                Assert.isNull(receptionServiceReq_3.getSendMsgScene(), "D3执行通知类型消息模板分析(公共)-M3约定下发公文给部门-发送消息场景不能为空", false);
                Assert.isNull(receptionServiceReq_3.getMessageTemplateCode(), "D3执行通知类型消息模板分析(公共)-M3约定下发公文给部门-消息模板标识不能为空", false);
                receptionServiceRes_6 = nbOfficialDocument.implementTypeCodeFieldsAccept(receptionServiceReq_3);


//ModelCode: receptionService
                ImplementTypeCodeFieldsAcceptRespDto receptionServiceRes_8 = null;
                ImplementTypeCodeFieldsAcceptReqDto receptionServiceReq_4 = new ImplementTypeCodeFieldsAcceptReqDto();
                if (receptionServiceRes_6 != null) {
                    receptionServiceReq_4.setSendMsgScene(receptionServiceRes_6.getSendMsgScene());//SimpleFieldAssign//sourceId:1464853_1_56678
                    receptionServiceReq_4.setMessageTemplateCode(receptionServiceRes_6.getMessageTemplateCode());//SimpleFieldAssign//sourceId:1464898_1_56678
                }
                if (receptionServiceRes != null) {
                    receptionServiceReq_4.setMsgTitleTemplateSemanticEngineCode(receptionServiceRes.getMsgTitleTemplateSemanticEngineCode());//SimpleFieldAssign//sourceId:1464870_1_56678
                }

                /*M3接收发消息业务场景[7735]  用于特殊方法接收上游入参。 */
                Assert.isNull(receptionServiceReq_4.getSendMsgScene(), "D3执行通知类型消息模板分析(公共)-M3接收发消息业务场景-发送消息场景不能为空", false);
                Assert.isNull(receptionServiceReq_4.getMessageTemplateCode(), "D3执行通知类型消息模板分析(公共)-M3接收发消息业务场景-消息模板标识不能为空", false);
                Assert.isNull(receptionServiceReq_4.getMsgTitleTemplateSemanticEngineCode(), "D3执行通知类型消息模板分析(公共)-M3接收发消息业务场景-消息标题模板引擎标识不能为空", false);
                receptionServiceRes_8 = nbOfficialDocument.implementTypeCodeFieldsAccept(receptionServiceReq_4);


                receptionServiceRes_5 = receptionServiceRes_8;
            } else if ((reqDto != null && reqDto.getReceiveRange() != null && reqDto.getReceiveRange().equals("PERSON"))) {
                //elseif(D3执行通知类型消息模板分析(公共).接收范围 等于 个人)  56683

//ModelCode: receptionService
                ImplementTypeCodeFieldsAcceptRespDto receptionServiceRes_9 = null;
                ImplementTypeCodeFieldsAcceptReqDto receptionServiceReq_5 = new ImplementTypeCodeFieldsAcceptReqDto();
                receptionServiceReq_5.setSendMsgScene("ISSUE_OFFICIAL_DOC_SEND_PERSON");//sourceId:1464857_1_56688
                receptionServiceReq_5.setMessageTemplateCode("ISSUE_OFFCIAL_DOC_TWO_PEOPLE_CHAT");//CUSTOM_CONVENTION//sourceId:1464902_1_56688

                /*M3约定下发公文给个人[7735]  用于特殊方法接收上游入参。 */
                Assert.isNull(receptionServiceReq_5.getSendMsgScene(), "D3执行通知类型消息模板分析(公共)-M3约定下发公文给个人-发送消息场景不能为空", false);
                Assert.isNull(receptionServiceReq_5.getMessageTemplateCode(), "D3执行通知类型消息模板分析(公共)-M3约定下发公文给个人-消息模板标识不能为空", false);
                receptionServiceRes_9 = nbOfficialDocument.implementTypeCodeFieldsAccept(receptionServiceReq_5);


//ModelCode: receptionService
                ImplementTypeCodeFieldsAcceptRespDto receptionServiceRes_11 = null;
                ImplementTypeCodeFieldsAcceptReqDto receptionServiceReq_6 = new ImplementTypeCodeFieldsAcceptReqDto();
                if (receptionServiceRes_9 != null) {
                    receptionServiceReq_6.setSendMsgScene(receptionServiceRes_9.getSendMsgScene());//SimpleFieldAssign//sourceId:1464853_1_56684
                    receptionServiceReq_6.setMessageTemplateCode(receptionServiceRes_9.getMessageTemplateCode());//SimpleFieldAssign//sourceId:1464898_1_56684
                }
                if (receptionServiceRes != null) {
                    receptionServiceReq_6.setMsgTitleTemplateSemanticEngineCode(receptionServiceRes.getMsgTitleTemplateSemanticEngineCode());//SimpleFieldAssign//sourceId:1464870_1_56684
                }

                /*M3接收发消息业务场景[7735]  用于特殊方法接收上游入参。 */
                Assert.isNull(receptionServiceReq_6.getSendMsgScene(), "D3执行通知类型消息模板分析(公共)-M3接收发消息业务场景-发送消息场景不能为空", false);
                Assert.isNull(receptionServiceReq_6.getMessageTemplateCode(), "D3执行通知类型消息模板分析(公共)-M3接收发消息业务场景-消息模板标识不能为空", false);
                Assert.isNull(receptionServiceReq_6.getMsgTitleTemplateSemanticEngineCode(), "D3执行通知类型消息模板分析(公共)-M3接收发消息业务场景-消息标题模板引擎标识不能为空", false);
                receptionServiceRes_11 = nbOfficialDocument.implementTypeCodeFieldsAccept(receptionServiceReq_6);


                receptionServiceRes_5 = receptionServiceRes_11;
            }
        } else if ((reqDto != null && reqDto.getNotificationType() != null && reqDto.getNotificationType().equals("NOTIFICATION"))) {
            //elseif(D3执行通知类型消息模板分析(公共).通知类型 等于 通知)  56668

//ModelCode: receptionService
            ImplementTypeCodeFieldsAcceptRespDto receptionServiceRes_12 = null;
            ImplementTypeCodeFieldsAcceptReqDto receptionServiceReq_7 = new ImplementTypeCodeFieldsAcceptReqDto();
            receptionServiceReq_7.setMsgTitleTemplateSemanticEngineCode("ISSUE_NOTIFICATION_TITLE");//CUSTOM_CONVENTION//sourceId:1464872_1_56679

            /*M3约定通知引擎模板标识[7735]  用于特殊方法接收上游入参。 */
            Assert.isNull(receptionServiceReq_7.getMsgTitleTemplateSemanticEngineCode(), "D3执行通知类型消息模板分析(公共)-M3约定通知引擎模板标识-消息标题模板引擎标识不能为空", false);
            receptionServiceRes_12 = nbOfficialDocument.implementTypeCodeFieldsAccept(receptionServiceReq_7);


            if ((reqDto != null && reqDto.getReceiveRange() != null && reqDto.getReceiveRange().equals("EVERYONE"))) {
                //if(D3执行通知类型消息模板分析(公共).接收范围 等于 所有人)  56680

//ModelCode: receptionService
                ImplementTypeCodeFieldsAcceptRespDto receptionServiceRes_14 = null;
                ImplementTypeCodeFieldsAcceptReqDto receptionServiceReq_8 = new ImplementTypeCodeFieldsAcceptReqDto();
                receptionServiceReq_8.setSendMsgScene("ISSUE_NOTIFICATION_SEND_EVERYONE");//sourceId:1464859_1_56696
                receptionServiceReq_8.setMessageTemplateCode("ISSUE_NOTIFICATION_ORG_GROUP");//CUSTOM_CONVENTION//sourceId:1465226_1_56696

                /*M3约定下发通知给所有人[7735]  用于特殊方法接收上游入参。 */
                Assert.isNull(receptionServiceReq_8.getSendMsgScene(), "D3执行通知类型消息模板分析(公共)-M3约定下发通知给所有人-发送消息场景不能为空", false);
                Assert.isNull(receptionServiceReq_8.getMessageTemplateCode(), "D3执行通知类型消息模板分析(公共)-M3约定下发通知给所有人-消息模板标识不能为空", false);
                receptionServiceRes_14 = nbOfficialDocument.implementTypeCodeFieldsAccept(receptionServiceReq_8);


//ModelCode: receptionService
                ImplementTypeCodeFieldsAcceptRespDto receptionServiceRes_16 = null;
                ImplementTypeCodeFieldsAcceptReqDto receptionServiceReq_9 = new ImplementTypeCodeFieldsAcceptReqDto();
                if (receptionServiceRes_14 != null) {
                    receptionServiceReq_9.setSendMsgScene(receptionServiceRes_14.getSendMsgScene());//SimpleFieldAssign//sourceId:1464853_1_56685
                    receptionServiceReq_9.setMessageTemplateCode(receptionServiceRes_14.getMessageTemplateCode());//SimpleFieldAssign//sourceId:1464898_1_56685
                }
                if (receptionServiceRes_12 != null) {
                    receptionServiceReq_9.setMsgTitleTemplateSemanticEngineCode(receptionServiceRes_12.getMsgTitleTemplateSemanticEngineCode());//SimpleFieldAssign//sourceId:1464870_1_56685
                }

                /*M3接收发消息业务场景[7735]  用于特殊方法接收上游入参。 */
                Assert.isNull(receptionServiceReq_9.getSendMsgScene(), "D3执行通知类型消息模板分析(公共)-M3接收发消息业务场景-发送消息场景不能为空", false);
                Assert.isNull(receptionServiceReq_9.getMessageTemplateCode(), "D3执行通知类型消息模板分析(公共)-M3接收发消息业务场景-消息模板标识不能为空", false);
                Assert.isNull(receptionServiceReq_9.getMsgTitleTemplateSemanticEngineCode(), "D3执行通知类型消息模板分析(公共)-M3接收发消息业务场景-消息标题模板引擎标识不能为空", false);
                receptionServiceRes_16 = nbOfficialDocument.implementTypeCodeFieldsAccept(receptionServiceReq_9);


                receptionServiceRes_5 = receptionServiceRes_16;
            } else if ((reqDto != null && reqDto.getReceiveRange() != null && reqDto.getReceiveRange().equals("DEPT"))) {
                //elseif(D3执行通知类型消息模板分析(公共).接收范围 等于 部门)  56681

//ModelCode: receptionService
                ImplementTypeCodeFieldsAcceptRespDto receptionServiceRes_17 = null;
                ImplementTypeCodeFieldsAcceptReqDto receptionServiceReq_10 = new ImplementTypeCodeFieldsAcceptReqDto();
                receptionServiceReq_10.setSendMsgScene("ISSUE_NOTIFICATION_SEND_DEPT");//sourceId:1464861_1_56697
                receptionServiceReq_10.setMessageTemplateCode("ISSUE_NOTIFICATION_DEPT_GROUP");//CUSTOM_CONVENTION//sourceId:1465228_1_56697

                /*M3约定下发通知给部门[7735]  用于特殊方法接收上游入参。 */
                Assert.isNull(receptionServiceReq_10.getSendMsgScene(), "D3执行通知类型消息模板分析(公共)-M3约定下发通知给部门-发送消息场景不能为空", false);
                Assert.isNull(receptionServiceReq_10.getMessageTemplateCode(), "D3执行通知类型消息模板分析(公共)-M3约定下发通知给部门-消息模板标识不能为空", false);
                receptionServiceRes_17 = nbOfficialDocument.implementTypeCodeFieldsAccept(receptionServiceReq_10);


//ModelCode: receptionService
                ImplementTypeCodeFieldsAcceptRespDto receptionServiceRes_19 = null;
                ImplementTypeCodeFieldsAcceptReqDto receptionServiceReq_11 = new ImplementTypeCodeFieldsAcceptReqDto();
                if (receptionServiceRes_17 != null) {
                    receptionServiceReq_11.setSendMsgScene(receptionServiceRes_17.getSendMsgScene());//SimpleFieldAssign//sourceId:1464853_1_56686
                    receptionServiceReq_11.setMessageTemplateCode(receptionServiceRes_17.getMessageTemplateCode());//SimpleFieldAssign//sourceId:1464898_1_56686
                }
                if (receptionServiceRes_12 != null) {
                    receptionServiceReq_11.setMsgTitleTemplateSemanticEngineCode(receptionServiceRes_12.getMsgTitleTemplateSemanticEngineCode());//SimpleFieldAssign//sourceId:1464870_1_56686
                }

                /*M3接收发消息业务场景[7735]  用于特殊方法接收上游入参。 */
                Assert.isNull(receptionServiceReq_11.getSendMsgScene(), "D3执行通知类型消息模板分析(公共)-M3接收发消息业务场景-发送消息场景不能为空", false);
                Assert.isNull(receptionServiceReq_11.getMessageTemplateCode(), "D3执行通知类型消息模板分析(公共)-M3接收发消息业务场景-消息模板标识不能为空", false);
                Assert.isNull(receptionServiceReq_11.getMsgTitleTemplateSemanticEngineCode(), "D3执行通知类型消息模板分析(公共)-M3接收发消息业务场景-消息标题模板引擎标识不能为空", false);
                receptionServiceRes_19 = nbOfficialDocument.implementTypeCodeFieldsAccept(receptionServiceReq_11);


                receptionServiceRes_5 = receptionServiceRes_19;
            } else if ((reqDto != null && reqDto.getReceiveRange() != null && reqDto.getReceiveRange().equals("PERSON"))) {
                //elseif(D3执行通知类型消息模板分析(公共).接收范围 等于 个人)  56682

//ModelCode: receptionService
                ImplementTypeCodeFieldsAcceptRespDto receptionServiceRes_20 = null;
                ImplementTypeCodeFieldsAcceptReqDto receptionServiceReq_12 = new ImplementTypeCodeFieldsAcceptReqDto();
                receptionServiceReq_12.setSendMsgScene("ISSUE_NOTIFICATION_SEND_PERSON");//sourceId:1464863_1_56698
                receptionServiceReq_12.setMessageTemplateCode("ISSUE_NOTIFICATION_TWO_PEOPLE_CHAT");//CUSTOM_CONVENTION//sourceId:1465230_1_56698

                /*M3约定下发通知给个人[7735]  用于特殊方法接收上游入参。 */
                Assert.isNull(receptionServiceReq_12.getSendMsgScene(), "D3执行通知类型消息模板分析(公共)-M3约定下发通知给个人-发送消息场景不能为空", false);
                Assert.isNull(receptionServiceReq_12.getMessageTemplateCode(), "D3执行通知类型消息模板分析(公共)-M3约定下发通知给个人-消息模板标识不能为空", false);
                receptionServiceRes_20 = nbOfficialDocument.implementTypeCodeFieldsAccept(receptionServiceReq_12);


//ModelCode: receptionService
                ImplementTypeCodeFieldsAcceptRespDto receptionServiceRes_22 = null;
                ImplementTypeCodeFieldsAcceptReqDto receptionServiceReq_13 = new ImplementTypeCodeFieldsAcceptReqDto();
                if (receptionServiceRes_20 != null) {
                    receptionServiceReq_13.setSendMsgScene(receptionServiceRes_20.getSendMsgScene());//SimpleFieldAssign//sourceId:1464853_1_56687
                    receptionServiceReq_13.setMessageTemplateCode(receptionServiceRes_20.getMessageTemplateCode());//SimpleFieldAssign//sourceId:1464898_1_56687
                }
                if (receptionServiceRes_12 != null) {
                    receptionServiceReq_13.setMsgTitleTemplateSemanticEngineCode(receptionServiceRes_12.getMsgTitleTemplateSemanticEngineCode());//SimpleFieldAssign//sourceId:1464870_1_56687
                }

                /*M3接收发消息业务场景[7735]  用于特殊方法接收上游入参。 */
                Assert.isNull(receptionServiceReq_13.getSendMsgScene(), "D3执行通知类型消息模板分析(公共)-M3接收发消息业务场景-发送消息场景不能为空", false);
                Assert.isNull(receptionServiceReq_13.getMessageTemplateCode(), "D3执行通知类型消息模板分析(公共)-M3接收发消息业务场景-消息模板标识不能为空", false);
                Assert.isNull(receptionServiceReq_13.getMsgTitleTemplateSemanticEngineCode(), "D3执行通知类型消息模板分析(公共)-M3接收发消息业务场景-消息标题模板引擎标识不能为空", false);
                receptionServiceRes_22 = nbOfficialDocument.implementTypeCodeFieldsAccept(receptionServiceReq_13);


                receptionServiceRes_5 = receptionServiceRes_22;
            }
        }
        ImplementNotificationTypeMsgTempanAlyzeComRespDto retData = new ImplementNotificationTypeMsgTempanAlyzeComRespDto();
        if (receptionServiceRes_5 != null) {
            retData.setSendMsgScene(receptionServiceRes_5.getSendMsgScene());//SimpleFieldAssign//sourceId:1464874_1
            retData.setMessageTemplateCode(receptionServiceRes_5.getMessageTemplateCode());//SimpleFieldAssign//sourceId:1465232_1
            retData.setMsgTitleTemplateSemanticEngineCode(receptionServiceRes_5.getMsgTitleTemplateSemanticEngineCode());//SimpleFieldAssign//sourceId:1464875_1
        }


        return retData;
    }

    /**
     * D3分析通知类型行为类型(公共)[8362]
     * gen by moon at 1/27/2024, 10:23:48 PM
     */
    @Trace(operationName = "D3分析通知类型行为类型(公共)")
    @Tags({@Tag(key = "参数", value = "arg[0]"),
            @Tag(key = "返回值", value = "returnedObj")})
    @Transactional(rollbackFor = Exception.class)
    @Override
    public AnalysisNotificationTypeBehaviorTypeComRespDto analysisNotificationTypeBehaviorTypeCom(AnalysisNotificationTypeBehaviorTypeComReqDto reqDto) {


        ImplementFourthReceivingFieldRespDto receptionServiceRes_3 = null;
//virtualUsage M3约定公文通知行为类型  60326
        //ModelCode: receptionService
        ImplementFourthReceivingFieldRespDto receptionServiceRes = null;
        ImplementFourthReceivingFieldReqDto receptionServiceReq = new ImplementFourthReceivingFieldReqDto();
        receptionServiceReq.setCustomField1("ISSUE_OFFCIAL_DOC");//CUSTOM_CONVENTION//sourceId:1510974_1_60326
        receptionServiceReq.setCustomField2("ISSUE_NOTIFICATION");//CUSTOM_CONVENTION//sourceId:1510975_1_60326

        /*M3约定公文通知行为类型[8259]  用于特殊方法接收上游入参。 */
        Assert.isNull(receptionServiceReq.getCustomField1(), "D3分析通知类型行为类型(公共)-M3约定公文通知行为类型-自定义字段1不能为空", false);
        Assert.isNull(receptionServiceReq.getCustomField2(), "D3分析通知类型行为类型(公共)-M3约定公文通知行为类型-自定义字段2不能为空", false);
        receptionServiceRes = nbOfficialDocument.implementFourthReceivingField(receptionServiceReq);


        if ((reqDto != null && reqDto.getNotificationType() != null && reqDto.getNotificationType().equals("OFFICIAL_DOCUMENT"))) {
            //if(D3分析通知类型行为类型(公共).通知类型 等于 公文)  60325

//ModelCode: receptionService
            ImplementFourthReceivingFieldRespDto receptionServiceRes_2 = null;
            ImplementFourthReceivingFieldReqDto receptionServiceReq_1 = new ImplementFourthReceivingFieldReqDto();
            if (receptionServiceRes != null) {
                receptionServiceReq_1.setBehaviorTypeCode(receptionServiceRes.getCustomField1());//SimpleFieldAssign//sourceId:1510982_1_60328
            }

            /*M3接收行为类型出参[8259]  用于特殊方法接收上游入参。 */
            Assert.isNull(receptionServiceReq_1.getBehaviorTypeCode(), "D3分析通知类型行为类型(公共)-M3接收行为类型出参-行为类型编码不能为空", false);
            receptionServiceRes_2 = nbOfficialDocument.implementFourthReceivingField(receptionServiceReq_1);


            receptionServiceRes_3 = receptionServiceRes_2;
        } else if ((reqDto != null && reqDto.getNotificationType() != null && reqDto.getNotificationType().equals("NOTIFICATION"))) {
            //elseif(D3分析通知类型行为类型(公共).通知类型 等于 通知)  60327

//ModelCode: receptionService
            ImplementFourthReceivingFieldRespDto receptionServiceRes_4 = null;
            ImplementFourthReceivingFieldReqDto receptionServiceReq_2 = new ImplementFourthReceivingFieldReqDto();
            if (receptionServiceRes != null) {
                receptionServiceReq_2.setBehaviorTypeCode(receptionServiceRes.getCustomField2());//SimpleFieldAssign//sourceId:1510982_1_60329
            }

            /*M3接收行为类型出参[8259]  用于特殊方法接收上游入参。 */
            Assert.isNull(receptionServiceReq_2.getBehaviorTypeCode(), "D3分析通知类型行为类型(公共)-M3接收行为类型出参-行为类型编码不能为空", false);
            receptionServiceRes_4 = nbOfficialDocument.implementFourthReceivingField(receptionServiceReq_2);


            receptionServiceRes_3 = receptionServiceRes_4;
        }
        AnalysisNotificationTypeBehaviorTypeComRespDto retData = new AnalysisNotificationTypeBehaviorTypeComRespDto();
        if (receptionServiceRes_3 != null) {
            retData.setBehaviorTypeCode(receptionServiceRes_3.getBehaviorTypeCode());//SimpleFieldAssign//sourceId:1510986_1
        }


        return retData;
    }
    //
}
